@NonNullApi
See: Description
| Interface | Description |
|---|---|
| ConsumerFactory<K,V> |
The strategy to produce a
Consumer instance(s). |
| ConsumerFactory.Listener<K,V> |
Called whenever a consumer is added or removed.
|
| KafkaFailureCallback<K,V> |
An enhanced
FailureCallback for reporting
KafkaProducerExceptions. |
| 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. |
| KafkaSendCallback<K,V> |
An enhanced
ListenableFutureCallback for reporting
KafkaProducerExceptions. |
| ProducerFactory<K,V> |
The strategy to produce a
Producer instance(s). |
| ProducerFactory.Listener<K,V> |
Called whenever a producer is added or removed.
|
| Class | Description |
|---|---|
| ABSwitchCluster |
A
Supplier for bootstrap servers that can toggle between 2 lists of servers. |
| CleanupConfig |
Specifies time of
KafkaStreams.cleanUp() execution. |
| DefaultKafkaConsumerFactory<K,V> |
The
ConsumerFactory implementation to produce new Consumer instances
for provided Map configs and optional Deserializers on each ConsumerFactory.createConsumer()
invocation. |
| DefaultKafkaProducerFactory<K,V> | |
| DefaultKafkaProducerFactory.CloseSafeProducer<K,V> |
A wrapper class for the delegate.
|
| KafkaAdmin |
An admin that delegates to an
AdminClient to create topics defined
in the application context. |
| KafkaResourceFactory |
Base class for consumer/producer/admin creators.
|
| KafkaResourceHolder<K,V> |
Kafka resource holder, wrapping a Kafka producer.
|
| KafkaTemplate<K,V> |
A template for executing high-level operations.
|
| MicrometerConsumerListener<K,V> |
A consumer factory listener that manages
KafkaClientMetrics. |
| MicrometerProducerListener<K,V> |
A producer factory listener that manages
KafkaClientMetrics. |
| ProducerFactoryUtils |
Helper class for managing a Spring based Kafka
DefaultKafkaProducerFactory
in particular for obtaining transactional Kafka resources for a given ProducerFactory. |
| RoutingKafkaTemplate |
A
KafkaTemplate that routes messages based on the topic name. |
| Exception | Description |
|---|---|
| KafkaProducerException |
Exceptions when producing.
|