| Package | Description |
|---|---|
| org.apache.twill.kafka.client |
This package provides Kafka client interfaces.
|
| Class and Description |
|---|
| BrokerInfo
Represents broker information.
|
| BrokerService
Service for providing information of kafka brokers.
|
| BrokerService.BrokerChangeListener
Listener for changes in broker list.
|
| Compression
An Enum representing different compression codec options for publishing messages.
|
| FetchedMessage |
| KafkaClient
Represents a kafka client that can publish/subscribe to a Kafka server cluster.
|
| 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.Ack
Represents the desired level of publish acknowledgment.
|
| KafkaPublisher.Preparer
A Preparer for preparing to publish messages to a given topic.
|
| TopicPartition
Represents a combination of topic and partition.
|
Copyright © 2013-2016 The Apache Software Foundation. All rights reserved.