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)
