Interface | Description |
---|---|
ConsumerFactory<K,V> |
The strategy to produce a
Consumer instance(s). |
KafkaOperations<K,V> |
The basic Kafka operations contract returning
ListenableFuture s. |
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 |
---|---|
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> | |
KafkaTemplate<K,V> |
A template for executing high-level operations.
|
Exception | Description |
---|---|
KafkaProducerException |
Exceptions when producing.
|