|
@@ -6,7 +6,6 @@ import org.apache.kafka.clients.consumer.KafkaConsumer;
|
|
|
import org.apache.kafka.clients.consumer.OffsetAndMetadata;
|
|
|
import org.apache.kafka.common.PartitionInfo;
|
|
|
import org.apache.kafka.common.TopicPartition;
|
|
|
-import org.apache.kafka.common.TopicPartitionInfo;
|
|
|
import org.apache.kafka.common.serialization.ByteArrayDeserializer;
|
|
|
import org.jetbrains.annotations.NotNull;
|
|
|
import org.slf4j.Logger;
|