Uses of Interface
org.apache.twill.kafka.client.KafkaConsumer.Preparer

Packages that use KafkaConsumer.Preparer

Package	Description
org.apache.twill.kafka.client	This package provides Kafka client interfaces.

Uses of KafkaConsumer.Preparer in org.apache.twill.kafka.client

Methods in org.apache.twill.kafka.client that return KafkaConsumer.Preparer

Modifier and Type	Method and Description
KafkaConsumer.Preparer	KafkaConsumer.Preparer.add(String topic, int partition, long offset) Consumes messages from a given offset.
KafkaConsumer.Preparer	KafkaConsumer.Preparer.addFromBeginning(String topic, int partition) Consumes messages from the earliest message available.
KafkaConsumer.Preparer	KafkaConsumer.Preparer.addLatest(String topic, int partition) Consumes messages from the latest message.
KafkaConsumer.Preparer	KafkaConsumer.prepare() Prepares for message consumption.