Philip Nee created KAFKA-15305:
----------------------------------
Summary: The background thread should try to process the remaining
task until the shutdown timer is expired
Key: KAFKA-15305
URL: https://issues.apache.org/jira/browse/KAFKA-15305
Project: Kafka
Issue Type: Sub-task
Components: consumer
Reporter: Philip Nee
Assignee: Philip Nee
While working on https://issues.apache.org/jira/browse/KAFKA-15304
close() API supplies a timeout parameter so that the consumer can have a grace
period to process things before shutting down. The background thread currently
doesn't do that, when close() is initiated, it will immediately close all of
its dependencies.
This might not be desirable because there could be remaining tasks to be
processed before closing. Maybe the correct things to do is to first stop
accepting API request, second, let the runOnce() continue to run before the
shutdown timer expires, then we can force closing all of its dependencies.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
