Chia-Ping Tsai created KAFKA-20426:
--------------------------------------
Summary: Using both group.id and assign() causes a busy loop in
AsyncKafkaConsumer
Key: KAFKA-20426
URL: https://issues.apache.org/jira/browse/KAFKA-20426
Project: Kafka
Issue Type: Bug
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
When using AsyncKafkaConsumer with a configured group.id, but relying on manual
assignment (consumer.assign()) instead of subscribe(), the pollForFetches will
return quickly and result in a busy loop.
The root cause is that the method
AbstractHeartbeatRequestManager#maximumTimeToWait always returns 0 since
heartbeatTimer is not updated when it is in the UNSUBSCRIBED state.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
