props.put(KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
props.put(VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
List<PartitionInfo> partitions = consumer.listTopics().get(this.topic);
Set<TopicPartition> assignment = new HashSet<>();
for (PartitionInfo info : partitions)
List<PartitionInfo> partitions = consumer.listTopics().get(this.topic);
Set<TopicPartition> assignment = new HashSet<>();
for (PartitionInfo info : partitions)
this.watermarks = new Watermarks(partitions.size());
long[] currentOffsets = new long[partitions.size()];
this.watermarks = new Watermarks(partitions.size());
long[] currentOffsets = new long[partitions.size()];