Package org.apache.kafka.clients.consumer

Class MockConsumer<K,V>

java.lang.Object

org.apache.kafka.clients.consumer.MockConsumer<K,V>

All Implemented Interfaces:

Closeable, AutoCloseable, Consumer<K,V>

public class MockConsumer<K,V>
extends Object
implements Consumer<K,V>

A mock of the Consumer interface you can use for testing code that uses Kafka. This class is not threadsafe . However, you can use the schedulePollTask(Runnable) method to write multithreaded tests where a driver thread waits for poll(Duration) to be called by a background thread and then can safely perform operations during a callback.

Constructor Summary

Constructors

Constructor	Description
MockConsumer(OffsetResetStrategy offsetResetStrategy)

Method Summary

Modifier and Type	Method	Description
void	addRecord(ConsumerRecord<K,V> record)
void	assign(Collection<TopicPartition> partitions)
Set<TopicPartition>	assignment()
Map<TopicPartition,Long>	beginningOffsets(Collection<TopicPartition> partitions)
Map<TopicPartition,Long>	beginningOffsets(Collection<TopicPartition> partitions, Duration timeout)
void	close()
void	close(Duration timeout)
boolean	closed()
void	commitAsync()
void	commitAsync(Map<TopicPartition,OffsetAndMetadata> offsets, OffsetCommitCallback callback)
void	commitAsync(OffsetCommitCallback callback)
void	commitSync()
void	commitSync(Duration timeout)
void	commitSync(Map<TopicPartition,OffsetAndMetadata> offsets)
void	commitSync(Map<TopicPartition,OffsetAndMetadata> offsets, Duration timeout)
Map<TopicPartition,OffsetAndMetadata>	committed(Set<TopicPartition> partitions)
Map<TopicPartition,OffsetAndMetadata>	committed(Set<TopicPartition> partitions, Duration timeout)
OffsetAndMetadata	committed(TopicPartition partition)	Deprecated.
OffsetAndMetadata	committed(TopicPartition partition, Duration timeout)	Deprecated.
OptionalLong	currentLag(TopicPartition topicPartition)
Map<TopicPartition,Long>	endOffsets(Collection<TopicPartition> partitions)
Map<TopicPartition,Long>	endOffsets(Collection<TopicPartition> partitions, Duration timeout)
void	enforceRebalance()
void	enforceRebalance(String reason)
ConsumerGroupMetadata	groupMetadata()
Duration	lastPollTimeout()
Map<String,List<PartitionInfo>>	listTopics()
Map<String,List<PartitionInfo>>	listTopics(Duration timeout)
Map<MetricName,? extends Metric>	metrics()
Map<TopicPartition,OffsetAndTimestamp>	offsetsForTimes(Map<TopicPartition,Long> timestampsToSearch)
Map<TopicPartition,OffsetAndTimestamp>	offsetsForTimes(Map<TopicPartition,Long> timestampsToSearch, Duration timeout)
List<PartitionInfo>	partitionsFor(String topic)
List<PartitionInfo>	partitionsFor(String topic, Duration timeout)
void	pause(Collection<TopicPartition> partitions)
Set<TopicPartition>	paused()
ConsumerRecords<K,V>	poll(long timeout)	Deprecated.
ConsumerRecords<K,V>	poll(Duration timeout)
long	position(TopicPartition partition)
long	position(TopicPartition partition, Duration timeout)
void	rebalance(Collection<TopicPartition> newAssignment)	Simulate a rebalance event.
void	resetShouldRebalance()
void	resume(Collection<TopicPartition> partitions)
void	scheduleNopPollTask()
void	schedulePollTask(Runnable task)	Schedule a task to be executed during a poll().
void	seek(TopicPartition partition, long offset)
void	seek(TopicPartition partition, OffsetAndMetadata offsetAndMetadata)
void	seekToBeginning(Collection<TopicPartition> partitions)
void	seekToEnd(Collection<TopicPartition> partitions)
void	setException(KafkaException exception)	Deprecated. Use setPollException(KafkaException) instead
void	setOffsetsException(KafkaException exception)
void	setPollException(KafkaException exception)
boolean	shouldRebalance()
void	subscribe(Collection<String> topics)
void	subscribe(Collection<String> topics, ConsumerRebalanceListener listener)
void	subscribe(Pattern pattern)
void	subscribe(Pattern pattern, ConsumerRebalanceListener listener)
Set<String>	subscription()
void	unsubscribe()
void	updateBeginningOffsets(Map<TopicPartition,Long> newOffsets)
void	updateEndOffsets(Map<TopicPartition,Long> newOffsets)
void	updatePartitions(String topic, List<PartitionInfo> partitions)
void	wakeup()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MockConsumer

public MockConsumer(OffsetResetStrategy offsetResetStrategy)

Method Details

assignment

public Set<TopicPartition> assignment()

Specified by:

assignment in interface Consumer<K,V>

See Also:

• KafkaConsumer.assignment()

rebalance

public void rebalance(Collection<TopicPartition> newAssignment)

Simulate a rebalance event.

subscription

public Set<String> subscription()

Specified by:

subscription in interface Consumer<K,V>

See Also:

• KafkaConsumer.subscription()

subscribe

public void subscribe(Collection<String> topics)

Specified by:

subscribe in interface Consumer<K,V>

See Also:

• KafkaConsumer.subscribe(Collection)

subscribe

public void subscribe(Pattern pattern,
 ConsumerRebalanceListener listener)

Specified by:

subscribe in interface Consumer<K,V>

See Also:

• KafkaConsumer.subscribe(Pattern, ConsumerRebalanceListener)

subscribe

public void subscribe(Pattern pattern)

Specified by:

subscribe in interface Consumer<K,V>

See Also:

• KafkaConsumer.subscribe(Pattern)

subscribe

public void subscribe(Collection<String> topics,
 ConsumerRebalanceListener listener)

Specified by:

subscribe in interface Consumer<K,V>

See Also:

• KafkaConsumer.subscribe(Collection, ConsumerRebalanceListener)

assign

public void assign(Collection<TopicPartition> partitions)

Specified by:

assign in interface Consumer<K,V>

See Also:

• KafkaConsumer.assign(Collection)

unsubscribe

public void unsubscribe()

Specified by:

unsubscribe in interface Consumer<K,V>

See Also:

• KafkaConsumer.unsubscribe()

poll

@Deprecated
public ConsumerRecords<K,V> poll(long timeout)

Deprecated.

Specified by:

poll in interface Consumer<K,V>

See Also:

• KafkaConsumer.poll(long)

poll

public ConsumerRecords<K,V> poll(Duration timeout)

Specified by:

poll in interface Consumer<K,V>

See Also:

• KafkaConsumer.poll(Duration)

addRecord

public void addRecord(ConsumerRecord<K,V> record)

setException

@Deprecated
public void setException(KafkaException exception)

Deprecated.

Use setPollException(KafkaException) instead

setPollException

public void setPollException(KafkaException exception)

setOffsetsException

public void setOffsetsException(KafkaException exception)

commitAsync

public void commitAsync(Map<TopicPartition,OffsetAndMetadata> offsets,
 OffsetCommitCallback callback)

Specified by:

commitAsync in interface Consumer<K,V>

See Also:

• KafkaConsumer.commitAsync(Map, OffsetCommitCallback)

commitSync

public void commitSync(Map<TopicPartition,OffsetAndMetadata> offsets)

Specified by:

commitSync in interface Consumer<K,V>

See Also:

• KafkaConsumer.commitSync(Map)

commitAsync

public void commitAsync()

Specified by:

commitAsync in interface Consumer<K,V>

See Also:

• KafkaConsumer.commitAsync()

commitAsync

public void commitAsync(OffsetCommitCallback callback)

Specified by:

commitAsync in interface Consumer<K,V>

See Also:

• KafkaConsumer.commitAsync(OffsetCommitCallback)

commitSync

public void commitSync()

Specified by:

commitSync in interface Consumer<K,V>

See Also:

• KafkaConsumer.commitSync()

commitSync

public void commitSync(Duration timeout)

Specified by:

commitSync in interface Consumer<K,V>

See Also:

• KafkaConsumer.commitSync(Duration)

commitSync

public void commitSync(Map<TopicPartition,OffsetAndMetadata> offsets,
 Duration timeout)

Specified by:

commitSync in interface Consumer<K,V>

See Also:

• KafkaConsumer.commitSync(Map, Duration)

seek

public void seek(TopicPartition partition,
 long offset)

Specified by:

seek in interface Consumer<K,V>

See Also:

• KafkaConsumer.seek(TopicPartition, long)

seek

public void seek(TopicPartition partition,
 OffsetAndMetadata offsetAndMetadata)

Specified by:

seek in interface Consumer<K,V>

See Also:

• KafkaConsumer.seek(TopicPartition, OffsetAndMetadata)

committed

@Deprecated
public OffsetAndMetadata committed(TopicPartition partition)

Deprecated.

Specified by:

committed in interface Consumer<K,V>

See Also:

• KafkaConsumer.committed(TopicPartition)

committed

@Deprecated
public OffsetAndMetadata committed(TopicPartition partition,
 Duration timeout)

Deprecated.

Specified by:

committed in interface Consumer<K,V>

See Also:

• KafkaConsumer.committed(TopicPartition, Duration)

committed

public Map<TopicPartition,OffsetAndMetadata> committed(Set<TopicPartition> partitions)

Specified by:

committed in interface Consumer<K,V>

See Also:

• KafkaConsumer.committed(Set)

committed

public Map<TopicPartition,OffsetAndMetadata> committed(Set<TopicPartition> partitions,
 Duration timeout)

Specified by:

committed in interface Consumer<K,V>

See Also:

• KafkaConsumer.committed(Set, Duration)

position

public long position(TopicPartition partition)

Specified by:

position in interface Consumer<K,V>

See Also:

• KafkaConsumer.position(TopicPartition)

position

public long position(TopicPartition partition,
 Duration timeout)

Specified by:

position in interface Consumer<K,V>

See Also:

• KafkaConsumer.position(TopicPartition, Duration)

seekToBeginning

public void seekToBeginning(Collection<TopicPartition> partitions)

Specified by:

seekToBeginning in interface Consumer<K,V>

See Also:

• KafkaConsumer.seekToBeginning(Collection)

updateBeginningOffsets

public void updateBeginningOffsets(Map<TopicPartition,Long> newOffsets)

seekToEnd

public void seekToEnd(Collection<TopicPartition> partitions)

Specified by:

seekToEnd in interface Consumer<K,V>

See Also:

• KafkaConsumer.seekToEnd(Collection)

updateEndOffsets

public void updateEndOffsets(Map<TopicPartition,Long> newOffsets)

metrics

public Map<MetricName,? extends Metric> metrics()

Specified by:

metrics in interface Consumer<K,V>

See Also:

• KafkaConsumer.metrics()

partitionsFor

public List<PartitionInfo> partitionsFor(String topic)

Specified by:

partitionsFor in interface Consumer<K,V>

See Also:

• KafkaConsumer.partitionsFor(String)

listTopics

public Map<String,List<PartitionInfo>> listTopics()

Specified by:

listTopics in interface Consumer<K,V>

See Also:

• KafkaConsumer.listTopics()

updatePartitions

public void updatePartitions(String topic,
 List<PartitionInfo> partitions)

pause

public void pause(Collection<TopicPartition> partitions)

Specified by:

pause in interface Consumer<K,V>

See Also:

• KafkaConsumer.pause(Collection)

resume

public void resume(Collection<TopicPartition> partitions)

Specified by:

resume in interface Consumer<K,V>

See Also:

• KafkaConsumer.resume(Collection)

offsetsForTimes

public Map<TopicPartition,OffsetAndTimestamp> offsetsForTimes(Map<TopicPartition,Long> timestampsToSearch)

Specified by:

offsetsForTimes in interface Consumer<K,V>

See Also:

• KafkaConsumer.offsetsForTimes(Map)

beginningOffsets

public Map<TopicPartition,Long> beginningOffsets(Collection<TopicPartition> partitions)

Specified by:

beginningOffsets in interface Consumer<K,V>

See Also:

• KafkaConsumer.beginningOffsets(Collection)

endOffsets

public Map<TopicPartition,Long> endOffsets(Collection<TopicPartition> partitions)

Specified by:

endOffsets in interface Consumer<K,V>

See Also:

• KafkaConsumer.endOffsets(Collection)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Consumer<K,V>

See Also:

• KafkaConsumer.close()

close

public void close(Duration timeout)

Specified by:

close in interface Consumer<K,V>

See Also:

• KafkaConsumer.close(Duration)

closed

public boolean closed()

wakeup

public void wakeup()

Specified by:

wakeup in interface Consumer<K,V>

See Also:

• KafkaConsumer.wakeup()

schedulePollTask

public void schedulePollTask(Runnable task)

Schedule a task to be executed during a poll(). One enqueued task will be executed per poll(Duration) invocation. You can use this repeatedly to mock out multiple responses to poll invocations.

Parameters:

task - the task to be executed

scheduleNopPollTask

public void scheduleNopPollTask()

paused

public Set<TopicPartition> paused()

Specified by:

paused in interface Consumer<K,V>

See Also:

• KafkaConsumer.paused()

partitionsFor

public List<PartitionInfo> partitionsFor(String topic,
 Duration timeout)

Specified by:

partitionsFor in interface Consumer<K,V>

See Also:

• KafkaConsumer.partitionsFor(String, Duration)

listTopics

public Map<String,List<PartitionInfo>> listTopics(Duration timeout)

Specified by:

listTopics in interface Consumer<K,V>

See Also:

• KafkaConsumer.listTopics(Duration)

offsetsForTimes

public Map<TopicPartition,OffsetAndTimestamp> offsetsForTimes(Map<TopicPartition,Long> timestampsToSearch,
 Duration timeout)

Specified by:

offsetsForTimes in interface Consumer<K,V>

See Also:

• KafkaConsumer.offsetsForTimes(Map, Duration)

beginningOffsets

public Map<TopicPartition,Long> beginningOffsets(Collection<TopicPartition> partitions,
 Duration timeout)

Specified by:

beginningOffsets in interface Consumer<K,V>

See Also:

• KafkaConsumer.beginningOffsets(Collection, Duration)

endOffsets

public Map<TopicPartition,Long> endOffsets(Collection<TopicPartition> partitions,
 Duration timeout)

Specified by:

endOffsets in interface Consumer<K,V>

See Also:

• KafkaConsumer.endOffsets(Collection, Duration)

currentLag

public OptionalLong currentLag(TopicPartition topicPartition)

Specified by:

currentLag in interface Consumer<K,V>

See Also:

• KafkaConsumer.currentLag(TopicPartition)

groupMetadata

public ConsumerGroupMetadata groupMetadata()

Specified by:

groupMetadata in interface Consumer<K,V>

See Also:

• KafkaConsumer.groupMetadata()

enforceRebalance

public void enforceRebalance()

Specified by:

enforceRebalance in interface Consumer<K,V>

See Also:

• KafkaConsumer.enforceRebalance()

enforceRebalance

public void enforceRebalance(String reason)

Specified by:

enforceRebalance in interface Consumer<K,V>

See Also:

• KafkaConsumer.enforceRebalance(String)

shouldRebalance

public boolean shouldRebalance()

resetShouldRebalance

public void resetShouldRebalance()

lastPollTimeout

public Duration lastPollTimeout()