Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

In KAFKA-4879, we first noticed that KafkaConsumer will hang forever when deleting a topic. However, after looking closer, we have found that in general the position(TopicPartition topicPartition) ,commitSync()committed() , and poll() (since pollOnce() calls updateFetchPositions() which blocks through a series of callbacks) method will continue to block indefinitely unless the offsets are retrieved for the provided TopicPartition.  To avoid this scenario from occurring:

...