@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.
|
ConsumerPostProcessor<K,V> |
Called by consumer factories to perform post processing on newly created consumers.
|
KafkaFailureCallback<K,V> |
An enhanced
FailureCallback for reporting
KafkaProducerException s. |
KafkaOperations<K,V> |
The basic Kafka operations contract returning
ListenableFuture s. |
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
KafkaProducerException s. |
ProducerFactory<K,V> |
The strategy to produce a
Producer instance(s). |
ProducerFactory.Listener<K,V> |
Called whenever a producer is added or removed.
|
ProducerPostProcessor<K,V> |
Called by producer factories to perform post processing on newly created producers.
|
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 Deserializer s 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.
|