...
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.
...