|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
See:
Description
Interface Summary | |
---|---|
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 Summary | |
---|---|
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 Summary | |
---|---|
ConsumerException | Wraps exceptions thrown by SimpleConsumer calls. |
PartitionNotFoundException | |
TopicNotFoundException |
Provides core classes of the Kafka module.
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |