public class MockShareConsumer<K,V> extends Object implements ShareConsumer<K,V>
ShareConsumer
interface you can use for testing code that uses Kafka. This class is not
thread-safe .Constructor and Description |
---|
MockShareConsumer() |
Modifier and Type | Method and 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)
|
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() |
public Set<String> subscription()
subscription
in interface ShareConsumer<K,V>
KafkaShareConsumer.subscription()
public void subscribe(Collection<String> topics)
subscribe
in interface ShareConsumer<K,V>
KafkaShareConsumer.subscribe(Collection)
public void unsubscribe()
unsubscribe
in interface ShareConsumer<K,V>
KafkaShareConsumer.unsubscribe()
public ConsumerRecords<K,V> poll(Duration timeout)
poll
in interface ShareConsumer<K,V>
KafkaShareConsumer.poll(Duration)
public void acknowledge(ConsumerRecord<K,V> record)
acknowledge
in interface ShareConsumer<K,V>
KafkaShareConsumer.acknowledge(ConsumerRecord)
public void acknowledge(ConsumerRecord<K,V> record, AcknowledgeType type)
acknowledge
in interface ShareConsumer<K,V>
KafkaShareConsumer.acknowledge(ConsumerRecord, AcknowledgeType)
public Map<TopicIdPartition,Optional<KafkaException>> commitSync()
commitSync
in interface ShareConsumer<K,V>
KafkaShareConsumer.commitSync()
public Map<TopicIdPartition,Optional<KafkaException>> commitSync(Duration timeout)
commitSync
in interface ShareConsumer<K,V>
KafkaShareConsumer.commitSync(Duration)
public void commitAsync()
commitAsync
in interface ShareConsumer<K,V>
KafkaShareConsumer.commitAsync()
public void setAcknowledgementCommitCallback(AcknowledgementCommitCallback callback)
setAcknowledgementCommitCallback
in interface ShareConsumer<K,V>
KafkaShareConsumer.setAcknowledgementCommitCallback(AcknowledgementCommitCallback)
public void setClientInstanceId(Uuid clientInstanceId)
public Uuid clientInstanceId(Duration timeout)
ShareConsumer
clientInstanceId
in interface ShareConsumer<K,V>
public Map<MetricName,? extends Metric> metrics()
metrics
in interface ShareConsumer<K,V>
KafkaShareConsumer.metrics()
public void close()
close
in interface Closeable
close
in interface AutoCloseable
close
in interface ShareConsumer<K,V>
KafkaShareConsumer.close()
public void close(Duration timeout)
close
in interface ShareConsumer<K,V>
KafkaShareConsumer.close(Duration)
public void wakeup()
wakeup
in interface ShareConsumer<K,V>
KafkaShareConsumer.wakeup()
public void addRecord(ConsumerRecord<K,V> record)