public class KafkaMessageSender<T extends com.google.protobuf.GeneratedMessage> extends Object implements org.apache.sling.distribution.journal.MessageSender<T>
Constructor and Description |
---|
KafkaMessageSender(org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer) |
public KafkaMessageSender(org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.