[GitHub] [kafka] showuon commented on pull request #13270: KAFKA-14729: The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

showuon commented on PR #13270: URL: https://github.com/apache/kafka/pull/13270#issuecomment-1442748397 > Hi @showuon Thank you for your reply. Happy to submit a short-term solution. I will submit new code changes later. Thanks. Great! Thank you! -- This is an automated message fro

[GitHub] [kafka] showuon commented on pull request #13270: KAFKA-14729: The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

showuon commented on PR #13270: URL: https://github.com/apache/kafka/pull/13270#issuecomment-1442732996 @RivenSun2 , I think what we're saying here, is we should throw exception in main consumer thread for a short-term solution. That is, throwing exception in `timeToNextHeartbeat` if heartb

[GitHub] [kafka] showuon commented on pull request #13270: KAFKA-14729: The kafakConsumer pollForFetches(timer) method takes up a lot of cpu due to the abnormal exit of the heartbeat thread

showuon commented on PR #13270: URL: https://github.com/apache/kafka/pull/13270#issuecomment-1435470639 > In general I think if the background thread dies for whatever the reason we should consider the following actions in precedence: 1. Make sure the consumer now falls into an abnor