See: Description
| Interface | Description |
|---|---|
| Callback |
A callback interface that the user can implement to allow code to execute when the request is complete.
|
| Partitioner |
Partitioner Interface
|
| Producer<K,V> |
The interface for the
KafkaProducer |
| ProducerInterceptor<K,V> |
A plugin interface that allows you to intercept (and possibly mutate) the records received by the producer before they are published to the Transactional Event Queues.
|
| Class | Description |
|---|---|
| KafkaProducer<K,V> |
Note: Topic name has to be in uppercase wherever used.
|
| ProducerConfig | |
| ProducerRecord<K,V> |
A key/value pair to be sent to TxEventQ.
|
| RecordMetadata |
The metadata for a record that has been acknowledged by the server
|
| Exception | Description |
|---|---|
| BufferExhaustedException |
This exception is thrown if the producer is in non-blocking mode and the rate of data production exceeds the rate at which data can be sent for long enough for the allocated buffer to be exhausted.
|