Child pages
  • KIP-266: Add TimeoutException to KafkaConsumer#position()

Versions Compared


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


Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).


Currently, in KafkaConsumer, the 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) method will continue to block indefinitely unless the offsets are retrieved for the provided TopicPartition.  To avoid this scenario from occurring, a TimeoutException will be thrown once the amount of time spent exceeds requestTimeoutMs which is a  user-configured variable.