KafkaDataManager changes
@@ -327,8 +327,6 @@ public class KafkaDataManager implements DataManager {
try {
consumer.seekToEnd(partitions);
- System.out.println(name2channel);
-
for (KafkaChannel channel : channels) {
positions.put(channel.getId(), consumer.position(channel.getTopicPartition()));
}
