org.apache.twill.kafka.client

Interface KafkaClientService

All Superinterfaces:

KafkaClient, com.google.common.util.concurrent.Service

public interface KafkaClientService
extends KafkaClient, com.google.common.util.concurrent.Service

A KafkaClient that extends Service to provide lifecycle management.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Method Summary

Methods inherited from interface org.apache.twill.kafka.client.KafkaClient

getConsumer, getPublisher

Methods inherited from interface com.google.common.util.concurrent.Service

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, failureCause, isRunning, start, startAndWait, startAsync, state, stop, stopAndWait, stopAsync