@Configuration @Requires(property="kafka.enabled", notEquals="false", defaultValue="true")
See: Description
| Interface | Description |
|---|---|
| ConsumerAware<K,V> |
Interface for
KafkaListener instances to implement
if they wish to obtain a reference to the underlying Consumer. |
| ConsumerRegistry |
A registry for created Kafka consumers.
|
| KafkaAcknowledgement |
Defines an interface that can be injected into
KafkaListener beans so that offsets can be manually committed. |
| ProducerFactory |
A factory class for creating Kafka
Producer instances. |
| ProducerRegistry |
A registry of managed
Producer instances key by id and type. |
| TransactionalProducerRegistry |
A registry of managed transactional
Producer instances key by id and type. |
| Class | Description |
|---|---|
| DefaultProducerFactory |
A default implementation of
ProducerFactory used for creating producer. |
| KafkaConsumerFactory |
A factory class for creating Kafka
Consumer instances. |
| KafkaHeaders |
A
MessageHeaders implementation for Kafka. |
| KafkaMessage<K,V> |
Message payload representation.
|
| KafkaMessage.Builder<K,V> |
The message builder.
|
| KafkaProducerFactory |
A registry class for Kafka
Producer instances. |