Module producer 

Producer types (org.apache.kafka.clients.producer)

Re-exports

pub use callback::Callback;

Modules

callback

Producer callback interface.

Structs

KafkaProducer

A Kafka client that publishes records to the Kafka cluster.

MockProducer

A mock of the producer interface for testing code that uses Kafka.

MockProducerOptions

Parameters for MockProducer::with_options.

MockProducerOptionsBuilder

Fluent builder for MockProducerOptions.

ProducerBufferExhaustedError

This error is returned if the producer cannot allocate memory for a record within max.block.ms due to the buffer being too full. In earlier versions a TimeoutError was returned instead of this. To keep existing checks working, Error::is_timeout_error answers true for it.

ProducerConfig

Configuration for the Kafka Producer. Documentation for these configurations can be found in the Kafka documentation.

ProducerRecord

A key/value pair to be sent to Kafka. This consists of a topic name to which the record is being sent, an optional partition number, and an optional key and value.

ProducerRecordOptions

The parameters of Java’s widest ProducerRecord constructor (ProducerRecord(String, Integer, Long, K, V, Iterable<Header>), ProducerRecord#ProducerRecord).

ProducerRecordOptionsBuilder

Fluent builder for ProducerRecordOptions.

RecordMetadata

The metadata for a record that has been acknowledged by the server.

RoundRobinPartitioner

The “Round-Robin” partitioner.

Traits

DynProducer

A dyn-compatible Producer, for holding different producer implementations behind one type, e.g. Vec<Box<dyn DynProducer<K, V>>>.

Partitioner

Partitioner Interface

Producer

The interface for the KafkaProducer.