Producer only send the "required_ack=all/1/0" in the request to the
partition leader.
Leader is responsible to make sure required_ack is fulfilled, then it ack
to client as producing succeeded.
On Mon, Dec 20, 2021 at 5:23 PM yonghua wrote:
> Hello,
>
> I am seeing this doc:
> https://github.co
Hello,
I am seeing this doc:
https://github.com/zendesk/ruby-kafka who says:
This behavior is controlled by the required_acks option to #producer and
#async_producer:
# This is the default: all replicas must acknowledge.
producer = kafka.producer(required_acks: :all)
My question
