lambdaliu created KAFKA-7811: -------------------------------- Summary: Avoid unnecessary lock acquire when KafkaConsumer commit offsets Key: KAFKA-7811 URL: https://issues.apache.org/jira/browse/KAFKA-7811 Project: Kafka Issue Type: Improvement Components: clients Affects Versions: 2.1.0, 2.0.1, 1.1.1, 1.0.2, 0.11.0.3, 0.10.2.2 Reporter: lambdaliu Assignee: lambdaliu
In KafkaConsumer#commitSync, we have the following logic: {code:java} public void commitAsync(OffsetCommitCallback callback) { acquireAndEnsureOpen(); try { commitAsync(subscriptions.allConsumed(), callback); } finally { release(); } } {code} This function calls another commitAsync which also call `acquireAndEnsureOpen`. -- This message was sent by Atlassian JIRA (v7.6.3#76005)