DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
In this KIP, we propose adding topic-level acks, enabling users reuse a single KafkaProducer even when different topics require different acks settings. This change will reduce the need for multiple producers, which is particularly beneficial in resource-constrained environments.
Public Interfaces
We add a new config TOPIC_ACKS_CONFIG and TOPIC_ACKS_DOC into ProducerConfig and define the format.
...
Name | Type | Importance | Default | Description |
|---|---|---|---|---|
| acks.topic.acks | String | LOW | null | This configuration item will set acks for specific topics. |
...
- Adding a new configuration in ProducerConfig : acks.topic.acks, By setting this configuration item, users can customize the acks for specific topic.
- Behavior change:
- Attach topic-level acks to RecordAccumulator#TopicInfo.
- Return Map<Acks, List<ProducerBatch>> when RecordAccumulator#drainBatchesForOneNode is called.
- Finally, we can get the acks information and group same acks into List<ProducerBatch>> for a node in sender#sendProduceRequests and then send request.
...