public class KafkaProducerWrapperWithTime<K,V>
extends org.apache.kafka.clients.producer.KafkaProducer<K,V>
Constructor and Description |
---|
KafkaProducerWrapperWithTime(Properties properties,
org.apache.kafka.common.utils.Time time) |
public KafkaProducerWrapperWithTime(Properties properties, org.apache.kafka.common.utils.Time time)