public interface KafkaClientService extends KafkaClient, com.google.common.util.concurrent.Service
KafkaClient
that extends Service
to provide lifecycle management.getConsumer, getPublisher
Copyright © 2013-2016 The Apache Software Foundation. All rights reserved.