public class MockConsumer<K,V> extends java.lang.Object implements Consumer<K,V>
Consumer
interface you can use for testing code that uses Kafka. This class is not
threadsafe
The consumer runs in the user thread and multiplexes I/O over TCP connections to each of the brokers it needs to communicate with. Failure to close the consumer after use will leak these resources.
Constructor and Description |
---|
MockConsumer() |
Modifier and Type | Method and Description |
---|---|
void |
addRecord(ConsumerRecord<K,V> record) |
void |
close() |
void |
commit(CommitType commitType) |
void |
commit(java.util.Map<TopicPartition,java.lang.Long> offsets,
CommitType commitType) |
long |
committed(TopicPartition partition) |
java.util.Map<MetricName,? extends Metric> |
metrics() |
java.util.List<PartitionInfo> |
partitionsFor(java.lang.String topic) |
ConsumerRecords<K,V> |
poll(long timeout) |
long |
position(TopicPartition partition) |
void |
seek(TopicPartition partition,
long offset) |
void |
seekToBeginning(TopicPartition... partitions) |
void |
seekToEnd(TopicPartition... partitions) |
void |
subscribe(java.lang.String... topics) |
void |
subscribe(TopicPartition... partitions) |
java.util.Set<TopicPartition> |
subscriptions() |
void |
unsubscribe(java.lang.String... topics) |
void |
unsubscribe(TopicPartition... partitions) |
void |
updatePartitions(java.lang.String topic,
java.util.List<PartitionInfo> partitions) |
public java.util.Set<TopicPartition> subscriptions()
subscriptions
in interface Consumer<K,V>
KafkaConsumer.subscriptions()
public void subscribe(java.lang.String... topics)
subscribe
in interface Consumer<K,V>
KafkaConsumer.subscribe(String...)
public void subscribe(TopicPartition... partitions)
subscribe
in interface Consumer<K,V>
KafkaConsumer.subscribe(TopicPartition...)
public void unsubscribe(java.lang.String... topics)
unsubscribe
in interface Consumer<K,V>
KafkaConsumer.unsubscribe(String...)
public void unsubscribe(TopicPartition... partitions)
unsubscribe
in interface Consumer<K,V>
KafkaConsumer.unsubscribe(TopicPartition...)
public ConsumerRecords<K,V> poll(long timeout)
poll
in interface Consumer<K,V>
KafkaConsumer.poll(long)
public void addRecord(ConsumerRecord<K,V> record)
public void commit(java.util.Map<TopicPartition,java.lang.Long> offsets, CommitType commitType)
commit
in interface Consumer<K,V>
KafkaConsumer.commit(Map, CommitType)
public void commit(CommitType commitType)
commit
in interface Consumer<K,V>
KafkaConsumer.commit(CommitType)
public void seek(TopicPartition partition, long offset)
seek
in interface Consumer<K,V>
KafkaConsumer.seek(TopicPartition, long)
public long committed(TopicPartition partition)
committed
in interface Consumer<K,V>
KafkaConsumer.committed(TopicPartition)
public long position(TopicPartition partition)
position
in interface Consumer<K,V>
KafkaConsumer.position(TopicPartition)
public void seekToBeginning(TopicPartition... partitions)
seekToBeginning
in interface Consumer<K,V>
KafkaConsumer.seekToBeginning(TopicPartition...)
public void seekToEnd(TopicPartition... partitions)
seekToEnd
in interface Consumer<K,V>
KafkaConsumer.seekToEnd(TopicPartition...)
public java.util.Map<MetricName,? extends Metric> metrics()
metrics
in interface Consumer<K,V>
KafkaConsumer.metrics()
public java.util.List<PartitionInfo> partitionsFor(java.lang.String topic)
partitionsFor
in interface Consumer<K,V>
KafkaConsumer.partitionsFor(String)
public void updatePartitions(java.lang.String topic, java.util.List<PartitionInfo> partitions)
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in interface Consumer<K,V>
KafkaConsumer.close()