Interface BlockingRecordQueue<K,​V>

  • Type Parameters:
    K - the record-key type
    V - the record-value type
    All Known Implementing Classes:
    BasicBlockingRecordQueue, DelegateBlockingRecordQueue

    public interface BlockingRecordQueue<K,​V>
    A blocking queue that can be used for publishing key-value records from a Kafka Streams topology.
    Since:
    0.8.0