| Interface | Description |
|---|---|
| ConsumerFactory<K,V> |
The strategy to produce a
Consumer instance(s). |
| KafkaOperations<K,V> |
The basic Kafka operations contract returning
ListenableFutures. |
| KafkaOperations.OperationsCallback<K,V,T> |
A callback for executing arbitrary operations on the
KafkaOperations. |
| KafkaOperations.ProducerCallback<K,V,T> |
A callback for executing arbitrary operations on the
Producer. |
| ProducerFactory<K,V> |
The strategy to produce a
Producer instance(s). |
| Class | Description |
|---|---|
| CleanupConfig |
Specifies time of
KafkaStreams.cleanUp() execution. |
| DefaultKafkaConsumerFactory<K,V> |
The
ConsumerFactory implementation to produce a new Consumer instance
for provided Map configs and optional Deserializer keyDeserializer,
valueDeserializer implementations on each DefaultKafkaConsumerFactory.createConsumer()
invocation. |
| DefaultKafkaProducerFactory<K,V> | |
| KafkaAdmin |
An admin that delegates to an
AdminClient to create topics defined
in the application context. |
| KafkaResourceHolder<K,V> |
Kafka resource holder, wrapping a Kafka producer.
|
| KafkaTemplate<K,V> |
A template for executing high-level operations.
|
| ProducerFactoryUtils |
Helper class for managing a Spring based Kafka
DefaultKafkaProducerFactory
in particular for obtaining transactional Kafka resources for a given ProducerFactory. |
| StreamsBuilderFactoryBean |
An
AbstractFactoryBean for the StreamsBuilder instance
and lifecycle control for the internal KafkaStreams instance. |
| Exception | Description |
|---|---|
| KafkaProducerException |
Exceptions when producing.
|