Expand description
Producer types (org.apache.kafka.clients.producer)
Structs§
- Kafka
Producer - A Kafka client that publishes records to the Kafka cluster.
- Mock
Producer - A mock of the producer interface for testing code that uses Kafka.
- Mock
Producer Options - Parameters for
MockProducer::with_options. - Mock
Producer Options Builder - Fluent builder for
MockProducerOptions. - Producer
Buffer Exhausted Error - The producer cannot allocate memory for a record because the buffer pool is full and the max blocking time has elapsed.
- Producer
Config - Configuration for the Kafka Producer.
- Producer
Record - 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.
- Producer
Record Options - The parameters of Java’s widest
ProducerRecordconstructor (ProducerRecord(String, Integer, Long, K, V, Iterable<Header>),ProducerRecord.java:69). - Producer
Record Options Builder - Fluent builder for
ProducerRecordOptions. - Record
Metadata - The metadata for a record that has been acknowledged by the server.
- Round
Robin Partitioner - 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: compute the partition for a record.
- Producer
- The interface for the
KafkaProducer.
Type Aliases§
- Callback
- Type alias for the producer send callback.