MockConsumer (kafka 1.1.0 API)

java.lang.Object
- org.apache.kafka.clients.consumer.MockConsumer<K,V>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Consumer<K,V>
```
public class MockConsumer<K,V>
extends java.lang.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(long) to be called by a background thread and then can safely perform operations during a callback.

Constructor Summary

Constructors
Constructor Description

MockConsumer(OffsetResetStrategy offsetResetStrategy)

Constructors
Constructor	Description
`MockConsumer(OffsetResetStrategy offsetResetStrategy)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addEndOffsets(java.util.Map<TopicPartition,java.lang.Long> newOffsets)`
`void`	`addRecord(ConsumerRecord<K,V> record)`
`void`	`assign(java.util.Collection<TopicPartition> partitions)`
`java.util.Set<TopicPartition>`	`assignment()`
`java.util.Map<TopicPartition,java.lang.Long>`	`beginningOffsets(java.util.Collection<TopicPartition> partitions)`
`void`	`close()`
`void`	`close(long timeout, java.util.concurrent.TimeUnit unit)`
`boolean`	`closed()`
`void`	`commitAsync()`
`void`	`commitAsync(java.util.Map<TopicPartition,OffsetAndMetadata> offsets, OffsetCommitCallback callback)`
`void`	`commitAsync(OffsetCommitCallback callback)`
`void`	`commitSync()`
`void`	`commitSync(java.util.Map<TopicPartition,OffsetAndMetadata> offsets)`
`OffsetAndMetadata`	`committed(TopicPartition partition)`
`java.util.Map<TopicPartition,java.lang.Long>`	`endOffsets(java.util.Collection<TopicPartition> partitions)`
`java.util.Map<java.lang.String,java.util.List<PartitionInfo>>`	`listTopics()`
`java.util.Map<MetricName,? extends Metric>`	`metrics()`
`java.util.Map<TopicPartition,OffsetAndTimestamp>`	`offsetsForTimes(java.util.Map<TopicPartition,java.lang.Long> timestampsToSearch)`
`java.util.List<PartitionInfo>`	`partitionsFor(java.lang.String topic)`
`void`	`pause(java.util.Collection<TopicPartition> partitions)`
`java.util.Set<TopicPartition>`	`paused()`
`ConsumerRecords<K,V>`	`poll(long timeout)`
`long`	`position(TopicPartition partition)`
`void`	`rebalance(java.util.Collection<TopicPartition> newAssignment)`	Simulate a rebalance event.
`void`	`resume(java.util.Collection<TopicPartition> partitions)`
`void`	`scheduleNopPollTask()`
`void`	`schedulePollTask(java.lang.Runnable task)`	Schedule a task to be executed during a poll().
`void`	`seek(TopicPartition partition, long offset)`
`void`	`seekToBeginning(java.util.Collection<TopicPartition> partitions)`
`void`	`seekToEnd(java.util.Collection<TopicPartition> partitions)`
`void`	`setException(KafkaException exception)`
`void`	`subscribe(java.util.Collection<java.lang.String> topics)`
`void`	`subscribe(java.util.Collection<java.lang.String> topics, ConsumerRebalanceListener listener)`
`void`	`subscribe(java.util.regex.Pattern pattern)`
`void`	`subscribe(java.util.regex.Pattern pattern, ConsumerRebalanceListener listener)`
`java.util.Set<java.lang.String>`	`subscription()`
`void`	`unsubscribe()`
`void`	`updateBeginningOffsets(java.util.Map<TopicPartition,java.lang.Long> newOffsets)`
`void`	`updateEndOffsets(java.util.Map<TopicPartition,java.lang.Long> newOffsets)`
`void`	`updatePartitions(java.lang.String topic, java.util.List<PartitionInfo> partitions)`
`void`	`wakeup()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - MockConsumer
```
public MockConsumer(OffsetResetStrategy offsetResetStrategy)
```
- Method Detail
  - assignment
```
public java.util.Set<TopicPartition> assignment()
```
    Specified by:
    
    assignment in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.assignment()
  - rebalance
```
public void rebalance(java.util.Collection<TopicPartition> newAssignment)
```
    Simulate a rebalance event.
  - subscription
```
public java.util.Set<java.lang.String> subscription()
```
    Specified by:
    
    subscription in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.subscription()
  - subscribe
```
public void subscribe(java.util.Collection<java.lang.String> topics)
```
    Specified by:
    
    subscribe in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.subscribe(Collection)
  - subscribe
```
public void subscribe(java.util.regex.Pattern pattern,
                      ConsumerRebalanceListener listener)
```
    Specified by:
    
    subscribe in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.subscribe(Pattern, ConsumerRebalanceListener)
  - subscribe
```
public void subscribe(java.util.regex.Pattern pattern)
```
    Specified by:
    
    subscribe in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.subscribe(Pattern)
  - subscribe
```
public void subscribe(java.util.Collection<java.lang.String> topics,
                      ConsumerRebalanceListener listener)
```
    Specified by:
    
    subscribe in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.subscribe(Collection, ConsumerRebalanceListener)
  - assign
```
public void assign(java.util.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
```
public ConsumerRecords<K,V> poll(long timeout)
```
    Specified by:
    
    poll in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.poll(long)
  - addRecord
```
public void addRecord(ConsumerRecord<K,V> record)
```
  - setException
```
public void setException(KafkaException exception)
```
  - commitAsync
```
public void commitAsync(java.util.Map<TopicPartition,OffsetAndMetadata> offsets,
                        OffsetCommitCallback callback)
```
    Specified by:
    
    commitAsync in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.commitAsync(Map, OffsetCommitCallback)
  - commitSync
```
public void commitSync(java.util.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()
  - seek
```
public void seek(TopicPartition partition,
                 long offset)
```
    Specified by:
    
    seek in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.seek(TopicPartition, long)
  - committed
```
public OffsetAndMetadata committed(TopicPartition partition)
```
    Specified by:
    
    committed in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.committed(TopicPartition)
  - position
```
public long position(TopicPartition partition)
```
    Specified by:
    
    position in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.position(TopicPartition)
  - seekToBeginning
```
public void seekToBeginning(java.util.Collection<TopicPartition> partitions)
```
    Specified by:
    
    seekToBeginning in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.seekToBeginning(Collection)
  - updateBeginningOffsets
```
public void updateBeginningOffsets(java.util.Map<TopicPartition,java.lang.Long> newOffsets)
```
  - seekToEnd
```
public void seekToEnd(java.util.Collection<TopicPartition> partitions)
```
    Specified by:
    
    seekToEnd in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.seekToEnd(Collection)
  - addEndOffsets
```
public void addEndOffsets(java.util.Map<TopicPartition,java.lang.Long> newOffsets)
```
  - updateEndOffsets
```
public void updateEndOffsets(java.util.Map<TopicPartition,java.lang.Long> newOffsets)
```
  - metrics
```
public java.util.Map<MetricName,? extends Metric> metrics()
```
    Specified by:
    
    metrics in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.metrics()
  - partitionsFor
```
public java.util.List<PartitionInfo> partitionsFor(java.lang.String topic)
```
    Specified by:
    
    partitionsFor in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.partitionsFor(String)
  - listTopics
```
public java.util.Map<java.lang.String,java.util.List<PartitionInfo>> listTopics()
```
    Specified by:
    
    listTopics in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.listTopics()
  - updatePartitions
```
public void updatePartitions(java.lang.String topic,
                             java.util.List<PartitionInfo> partitions)
```
  - pause
```
public void pause(java.util.Collection<TopicPartition> partitions)
```
    Specified by:
    
    pause in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.pause(Collection)
  - resume
```
public void resume(java.util.Collection<TopicPartition> partitions)
```
    Specified by:
    
    resume in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.resume(Collection)
  - offsetsForTimes
```
public java.util.Map<TopicPartition,OffsetAndTimestamp> offsetsForTimes(java.util.Map<TopicPartition,java.lang.Long> timestampsToSearch)
```
    Specified by:
    
    offsetsForTimes in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.offsetsForTimes(java.util.Map)
  - beginningOffsets
```
public java.util.Map<TopicPartition,java.lang.Long> beginningOffsets(java.util.Collection<TopicPartition> partitions)
```
    Specified by:
    
    beginningOffsets in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.beginningOffsets(java.util.Collection)
  - endOffsets
```
public java.util.Map<TopicPartition,java.lang.Long> endOffsets(java.util.Collection<TopicPartition> partitions)
```
    Specified by:
    
    endOffsets in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.endOffsets(java.util.Collection)
  - close
```
public void close()
```
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Specified by:
    
    close in interface java.io.Closeable
    
    Specified by:
    
    close in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.close()
  - close
```
public void close(long timeout,
                  java.util.concurrent.TimeUnit unit)
```
    Specified by:
    
    close in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.close(long, TimeUnit)
  - closed
```
public boolean closed()
```
  - wakeup
```
public void wakeup()
```
    Specified by:
    
    wakeup in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.wakeup()
  - schedulePollTask
```
public void schedulePollTask(java.lang.Runnable task)
```
    Schedule a task to be executed during a poll(). One enqueued task will be executed per poll(long) 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 java.util.Set<TopicPartition> paused()
```
    Specified by:
    
    paused in interface Consumer<K,V>
    
    See Also:
    
    KafkaConsumer.paused()

Class MockConsumer<K,V>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

MockConsumer

Method Detail

assignment

rebalance

subscription

subscribe

subscribe

subscribe

subscribe

assign

unsubscribe

poll

addRecord

setException

commitAsync

commitSync

commitAsync

commitAsync

commitSync

seek

committed

position

seekToBeginning

updateBeginningOffsets

seekToEnd

addEndOffsets

updateEndOffsets

metrics

partitionsFor

listTopics

updatePartitions

pause

resume

offsetsForTimes

beginningOffsets

endOffsets

close

close

closed

wakeup

schedulePollTask

scheduleNopPollTask

paused