Class 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.