org.apache.twill.kafka.client

Interface KafkaClient

All Known Subinterfaces:

KafkaClientService

public interface KafkaClient

Represents a kafka client that can publish/subscribe to a Kafka server cluster.

Method Summary

Modifier and Type	Method and Description
KafkaConsumer	getConsumer() Creates a KafkaConsumer for consuming messages.
KafkaPublisher	getPublisher(KafkaPublisher.Ack ack, Compression compression) Creates a KafkaPublisher that is ready for publish.

Method Detail

getPublisher

KafkaPublisher getPublisher(KafkaPublisher.Ack ack,
                            Compression compression)

Creates a KafkaPublisher that is ready for publish.

Parameters:

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.

Returns:

A KafkaPublisher.

getConsumer

KafkaConsumer getConsumer()

Creates a KafkaConsumer for consuming messages.

Returns:

A KafkaConsumer.