See: Description
| Interface | Description |
|---|---|
| Configuration |
Used to configure a
DefaultConnectionFactory. |
| Connection |
A connection to a Kafka broker.
|
| ConnectionFactory |
Creates Kafka connections and retrieves metadata for topics and partitions.
|
| KafkaOperations |
| Class | Description |
|---|---|
| AbstractConfiguration |
Default implementation of a
Configuration, storing the default topic and partitions,
as well as connectivity parameters. |
| BrokerAddress |
Encapsulates the address of a Kafka broker.
|
| BrokerAddressListConfiguration |
Kafka
Configuration where the seed brokers are set up explicitly. |
| DefaultConnection |
A connection to a Kafka broker.
|
| DefaultConnectionFactory |
Default implementation of
ConnectionFactory |
| FetchRequest |
Encapsulates a request for fetching messages from the server.
|
| KafkaConsumerDefaults |
Kafka adapter specific message headers.
|
| KafkaMessage |
Wrapper around a
kafka message and its metadata. |
| KafkaMessageBatch |
A group of
KafkaMessages retrieved by a fetch operation |
| KafkaMessageMetadata |
Metadata for a Kafka
Message. |
| KafkaTemplate |
A template for executing high-level operations on a set of Kafka brokers.
|
| Partition |
A reference to a Kafka partition, with both topic and partition id
|
| Result<T> |
The result of a Kafka SimpleConsumer operation
|
| ZookeeperConfiguration |
Kafka
Configuration that uses a ZooKeeper connection for retrieving the list of seed brokers. |
| ZookeeperConnectDefaults |
| Exception | Description |
|---|---|
| ConsumerException |
Wraps exceptions thrown by
SimpleConsumer calls. |
| PartitionNotFoundException | |
| TopicNotFoundException |