public static interface StreamTask.ProducerSupplier
org.apache.kafka.clients.producer.Producer<byte[],byte[]>
get()
org.apache.kafka.clients.producer.Producer<byte[],byte[]> get()