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

StreamsKafkaClient should not use StreamsConfig.POLL_MS_CONFIG

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.10.2.1, 0.11.0.0
    • 0.10.2.2, 0.11.0.1, 1.0.0
    • streams
    • 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

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

            Dates

              Created:
              Updated:
              Resolved: