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.