| Interface | Description |
|---|---|
| ConsumerFactory<K,V> |
The strategy to produce a
Consumer instance(s). |
| KafkaOperations<K,V> |
The basic Kafka operations contract returning
ListenableFutures. |
| 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.
|