Package org.apache.twill.kafka.client

This package provides Kafka client interfaces.

See: Description

Interface Summary

Interface	Description
BrokerService	Service for providing information of kafka brokers.
FetchedMessage
KafkaClient	Represents a kafka client that can publish/subscribe to a Kafka server cluster.
KafkaClientService	A KafkaClient that extends Service to provide lifecycle management.
KafkaConsumer	A consumer for consuming (reading) messages published to a Kafka server cluster.
KafkaConsumer.MessageCallback	Callback for receiving new messages.
KafkaConsumer.Preparer	A builder for preparing message consumption.
KafkaPublisher	This interface is for publishing data to Kafka.
KafkaPublisher.Preparer	A Preparer for preparing to publish messages to a given topic.

Class Summary

Class	Description
BrokerInfo	Represents broker information.
BrokerService.BrokerChangeListener	Listener for changes in broker list.
TopicPartition	Represents a combination of topic and partition.

Enum Summary

Enum	Description
Compression	An Enum representing different compression codec options for publishing messages.
KafkaPublisher.Ack	Represents the desired level of publish acknowledgment.

Package org.apache.twill.kafka.client Description

This package provides Kafka client interfaces.