Description
The behaviour for KafkaConsumer.poll(Duration) when the calling thread is in interrupted state is to throw InterruptException. The AsyncKafkaConsumer doesn't do this. It only throws that exception if the interruption occurs while it is waiting.
Attachments
Issue Links
- links to