Spring Integration Kafka Support

Package org.springframework.integration.kafka.core

Provides core classes of the Kafka module.

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 explicitly.
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 Summary
ConsumerException Wraps exceptions thrown by SimpleConsumer calls.
TopicNotFoundException  
 

Package org.springframework.integration.kafka.core Description

Provides core classes of the Kafka module.


Spring Integration Kafka Support