a. Sync producer
b. request.required.acks = -1
c. compression.codec="gzip" with send(List)
I'm not quite sure what you meant by 2, but committed all or nothing can
somewhat be achieved by placing all messages in a batch in one compressed
message. So I suggested c) above.
Thanks,
Neha
On Fri, F
Hi:
If someone's intention is to implement a producer such that:
1. The call to send() blocks until the write is successful on the configured
number or replicas or max num of retries.
2. The call to send() takes in a configurable batch of messages that is
committed all or nothing.
what combinat
