Class KafkaMockConsumer

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.clients.consumer.Consumer

    public class KafkaMockConsumer
    extends org.apache.kafka.clients.consumer.MockConsumer
    A mock consumer to test Kafka adapter.
    • Constructor Summary

      Constructors 
      Constructor Description
      KafkaMockConsumer​(org.apache.kafka.clients.consumer.OffsetResetStrategy offsetResetStrategy)  
    • Method Summary

      • Methods inherited from class org.apache.kafka.clients.consumer.MockConsumer

        addEndOffsets, addRecord, assign, assignment, beginningOffsets, beginningOffsets, close, close, close, closed, commitAsync, commitAsync, commitAsync, commitSync, commitSync, commitSync, commitSync, committed, committed, endOffsets, endOffsets, listTopics, listTopics, metrics, offsetsForTimes, offsetsForTimes, partitionsFor, partitionsFor, pause, paused, poll, poll, position, position, rebalance, resume, scheduleNopPollTask, schedulePollTask, seek, seekToBeginning, seekToEnd, setException, subscribe, subscribe, subscribe, subscribe, subscription, unsubscribe, updateBeginningOffsets, updateEndOffsets, updatePartitions, wakeup
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • KafkaMockConsumer

        public KafkaMockConsumer​(org.apache.kafka.clients.consumer.OffsetResetStrategy offsetResetStrategy)