Page History

...

One change shall be made to KafkaConsumer#poll() whose calls in Kafka internals  (specifically fetchCommittedOffsets() ) will block indefinitely. This is the exact same problems problem as what other methods face (such as committed() and position()). To avoid blocking indefinitely, the new methods will take user-determined timeout to define the maximum amount of time for which a method blocks.

...