MINOR: Change the log output information in the KafkaConsumer assign method
Reviewers: Luke Chen
@@ -1120,7 +1120,7 @@ public class KafkaConsumer<K, V> implements Consumer<K, V> {
if (coordinator != null)
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)))
metadata.requestUpdateForNewTopics();
}
