root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

MINOR: Change the log output information in the KafkaConsumer assign method (#12026) 

Reviewers: Luke Chen <showuon@gmail.com>
This commit is contained in:
RivenSun 2022-04-11 10:06:56 +08:00 committed by GitHub
parent 6e9cd0c7f5
commit 4ad439c56d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java
View File

@ -1120,7 +1120,7 @@ public class KafkaConsumer<K, V> implements Consumer<K, V> {
if (coordinator != null) if (coordinator != null)
this.coordinator.maybeAutoCommitOffsetsAsync(time.milliseconds()); this.coordinator.maybeAutoCommitOffsetsAsync(time.milliseconds());
log.info("Subscribed to partition(s): {}", Utils.join(partitions, ", ")); log.info("Assigned to partition(s): {}", Utils.join(partitions, ", "));
if (this.subscriptions.assignFromUser(new HashSet<>(partitions))) if (this.subscriptions.assignFromUser(new HashSet<>(partitions)))
metadata.requestUpdateForNewTopics(); metadata.requestUpdateForNewTopics();
} }