|
|||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | ||||||||
| Interface Summary | |
|---|---|
| Callback | A callback interface that the user can implement to allow code to execute when the request is complete. |
| Producer<K,V> | The interface for the KafkaProducer |
| Class Summary | |
|---|---|
| KafkaProducer<K,V> | A Kafka client that publishes records to the Kafka cluster. |
| MockProducer | A mock of the producer interface you can use for testing code that uses Kafka. |
| ProducerConfig | Configuration for the Kafka Producer. |
| ProducerRecord<K,V> | A key/value pair to be sent to Kafka. |
| RecordMetadata | The metadata for a record that has been acknowledged by the server |
| Exception Summary | |
|---|---|
| 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 alloted buffer to be exhausted. |
|
|||||||||
| PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES | ||||||||