Interface StreamTask.ProducerSupplier

  • Enclosing class:
    StreamTask

    public static interface StreamTask.ProducerSupplier
    • Method Detail

      • get

        org.apache.kafka.clients.producer.Producer<byte[],​byte[]> get()