public interface KafkaClient
KafkaPublisher getPublisher(KafkaPublisher.Ack ack, Compression compression)
KafkaPublisherthat is ready for publish.
ack- Type of ack that the publisher would use for all it's publish.
compression- The compression type for messages published through the returned publisher.
Copyright © 2013-2016 The Apache Software Foundation. All rights reserved.