Name | Description | Type | Package | Framework |
BrokerInfo | Represents broker information. | Class | apache.twill.kafka.client | Apache Twill |
BrokerService | Service for providing information of kafka brokers. | Interface | apache.twill.kafka.client | Apache Twill |
BrokerService .BrokerChangeListener | Listener for changes in broker list. | Class | apache.twill.kafka.client.BrokerService | Apache Twill |
Compression | An Enum representing different compression codec options for publishing messages. | Class | apache.twill.kafka.client | Apache Twill |
FetchedMessage | Interface | apache.twill.kafka.client | Apache Twill | |
KafkaClient | Represents a kafka client that can publish/subscribe to a Kafka server cluster. | Interface | apache.twill.kafka.client | Apache Twill |
KafkaClientService | A KafkaClient that extends Service to provide lifecycle management. | Interface | apache.twill.kafka.client | Apache Twill |
KafkaConsumer | A consumer for consuming (reading) messages published to a Kafka server cluster. | Interface | apache.twill.kafka.client | Apache Twill |
KafkaConsumer .MessageCallback | Callback for receiving new messages. | Interface | apache.twill.kafka.client.KafkaConsumer | Apache Twill |
KafkaConsumer .Preparer | A builder for preparing message consumption. | Interface | apache.twill.kafka.client.KafkaConsumer | Apache Twill |
KafkaPublisher | This interface is for publishing data to Kafka. | Interface | apache.twill.kafka.client | Apache Twill |
KafkaPublisher .Ack | Represents the desired level of publish acknowledgment. | Class | apache.twill.kafka.client.KafkaPublisher | Apache Twill |
KafkaPublisher .Preparer | A Preparer for preparing to publish messages to a given topic. | Interface | apache.twill.kafka.client.KafkaPublisher | Apache Twill |
TopicPartition | Represents a combination of topic and partition. | Class | apache.twill.kafka.client | Apache Twill |