Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14048 The Next Generation of the Consumer Rebalance Protocol
  3. KAFKA-16831

CoordinatorRuntime should initialize MemoryRecordsBuilder with max batch size write limit

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 3.8.0
    • None
    • None

    Description

      Otherwise, we default to the min buffer size of 16384 for the write limit. This causes the coordinator to threw RecordTooLargeException even when it's under the 1MB max batch size limit.

      Attachments

        Issue Links

          links to

          Web Link GitHub Pull Request #16059

          Activity

            People

              jeffkbkim Jeff Kim
              jeffkbkim Jeff Kim
              David Jacot David Jacot
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: