Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5464

StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.10.2.1, 0.11.0.0
    • Fix Version/s: 0.10.2.2, 0.11.0.1, 1.0.0
    • Component/s: streams
    • Labels:
      None

      Description

      In StreamsKafkaClient we use an NetworkClient internally and call poll using StreamsConfig.POLL_MS_CONFIG as timeout.

      However, StreamsConfig.POLL_MS_CONFIG is solely meant to be applied to KafkaConsumer.poll() and it's incorrect to use it for the NetworkClient. If the config is increased, this can lead to a infinite rebalance and rebalance on the client side is increased and thus, the client is not able to meet broker enforced timeouts anymore.

        Attachments

          Activity

            People

            • Assignee:
              mjsax Matthias J. Sax
              Reporter:
              mjsax Matthias J. Sax
            • Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: