org.apache.kafka.clients.producer.ProducerRecord<K,V> producerRecord
java.util.Collection<E> partitions
java.util.Collection<E> partitions
java.util.Collection<E> partitions
java.lang.Object container
long idleTime
java.lang.String listenerId
java.util.List<E> topicPartitions
boolean paused
long timeSinceLastPoll
java.lang.String listenerId
java.util.List<E> topicPartitions
byte[] data
boolean isKey
ProducerFactory<K,V> producerFactory