Package org.apache.kafka.clients.consumer

Class MockShareConsumer<K,V>

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, ShareConsumer<K,V>

public class MockShareConsumer<K,V>
extends Object
implements ShareConsumer<K,V>

A mock of the ShareConsumer interface you can use for testing code that uses Kafka. This class is not thread-safe .

Constructor Summary

Constructors

Constructor	Description
MockShareConsumer()

Method Summary

Modifier and Type	Method	Description
void	acknowledge(ConsumerRecord<K,V> record)
void	acknowledge(ConsumerRecord<K,V> record, AcknowledgeType type)
void	addRecord(ConsumerRecord<K,V> record)
Uuid	clientInstanceId(Duration timeout)	See KafkaShareConsumer.clientInstanceId(Duration)}
void	close()
void	close(Duration timeout)
void	commitAsync()
Map<TopicIdPartition,Optional<KafkaException>>	commitSync()
Map<TopicIdPartition,Optional<KafkaException>>	commitSync(Duration timeout)
Map<MetricName,? extends Metric>	metrics()
ConsumerRecords<K,V>	poll(Duration timeout)
void	setAcknowledgementCommitCallback(AcknowledgementCommitCallback callback)
void	setClientInstanceId(Uuid clientInstanceId)
void	subscribe(Collection<String> topics)
Set<String>	subscription()
void	unsubscribe()
void	wakeup()

Methods inherited from class java.lang.Object

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

Constructor Details

MockShareConsumer

public MockShareConsumer()

Method Details

subscription

public Set<String> subscription()

Specified by:

subscription in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.subscription()

subscribe

public void subscribe(Collection<String> topics)

Specified by:

subscribe in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.subscribe(Collection)

unsubscribe

public void unsubscribe()

Specified by:

unsubscribe in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.unsubscribe()

poll

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

Specified by:

poll in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.poll(Duration)

acknowledge

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

Specified by:

acknowledge in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.acknowledge(ConsumerRecord)

acknowledge

public void acknowledge(ConsumerRecord<K,V> record,
 AcknowledgeType type)

Specified by:

acknowledge in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.acknowledge(ConsumerRecord, AcknowledgeType)

commitSync

public Map<TopicIdPartition,Optional<KafkaException>> commitSync()

Specified by:

commitSync in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.commitSync()

commitSync

public Map<TopicIdPartition,Optional<KafkaException>> commitSync(Duration timeout)

Specified by:

commitSync in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.commitSync(Duration)

commitAsync

public void commitAsync()

Specified by:

commitAsync in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.commitAsync()

setAcknowledgementCommitCallback

public void setAcknowledgementCommitCallback(AcknowledgementCommitCallback callback)

Specified by:

setAcknowledgementCommitCallback in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.setAcknowledgementCommitCallback(AcknowledgementCommitCallback)

setClientInstanceId

public void setClientInstanceId(Uuid clientInstanceId)

clientInstanceId

public Uuid clientInstanceId(Duration timeout)

Description copied from interface: ShareConsumer

See KafkaShareConsumer.clientInstanceId(Duration)}

Specified by:

clientInstanceId in interface ShareConsumer<K,V>

metrics

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

Specified by:

metrics in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.metrics()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.close()

close

public void close(Duration timeout)

Specified by:

close in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.close(Duration)

wakeup

public void wakeup()

Specified by:

wakeup in interface ShareConsumer<K,V>

See Also:

• KafkaShareConsumer.wakeup()

addRecord

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