public class KafkaConsumerCallBridge extends Object
KafkaConsumer
.
This indirection is necessary, because Kafka broke binary compatibility between 0.9 and 0.10,
for example changing assign(List)
to assign(Collection)
.
Because of that, we need to have two versions whose compiled code goes against different method signatures. Even though the source of subclasses may look identical, the byte code will be different, because they are compiled against different dependencies.
Constructor and Description |
---|
KafkaConsumerCallBridge() |
Modifier and Type | Method and Description |
---|---|
void |
assignPartitions(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer,
List<org.apache.kafka.common.TopicPartition> topicPartitions) |
void |
seekPartitionToBeginning(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer,
org.apache.kafka.common.TopicPartition partition) |
void |
seekPartitionToEnd(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer,
org.apache.kafka.common.TopicPartition partition) |
public void assignPartitions(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer, List<org.apache.kafka.common.TopicPartition> topicPartitions) throws Exception
Exception
public void seekPartitionToBeginning(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer, org.apache.kafka.common.TopicPartition partition)
public void seekPartitionToEnd(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer, org.apache.kafka.common.TopicPartition partition)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.