kirktrue commented on PR #18702: URL: https://github.com/apache/kafka/pull/18702#issuecomment-2616799271
So given this configuration: ``` request.timeout.ms=30000 group.protocol=classic ``` When the user calls `Consumer.close(Duration.ofSeconds(60))`, it will complete in 30 seconds, not 60 seconds? If so, it means the user's timeout parameter is ignored, right? The change to the timeout behavior was introduced relatively recently in 3.5 via KAFKA-7109. Looking at #12590, I'm not sure the change to ignore the user's timeout was necessarily intentional. When closing, individual network requests should adhere to `request.timeout.ms`, but the overall timeout for closing should adhere to the user-provided timeout. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
