org.apache.twill.kafka.client

Interface KafkaConsumer

public interface KafkaConsumer

A consumer for consuming (reading) messages published to a Kafka server cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	KafkaConsumer.MessageCallback Callback for receiving new messages.
static interface	KafkaConsumer.Preparer A builder for preparing message consumption.

Method Summary

Modifier and Type	Method and Description
KafkaConsumer.Preparer	prepare() Prepares for message consumption.

Method Detail

prepare

KafkaConsumer.Preparer prepare()

Prepares for message consumption.

Returns:

A KafkaConsumer.Preparer to setup details about message consumption.