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
KafkaMessage s 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 |