Hi group,
I am wondering what is the retry behavior of asynchronous producer. Does
asynchronous producer retry to send messages if it doesn't receive a
response from a broker for a certain amount of time?
Thank you for the help!
Trinity
ated issue with regard to transnational markers:
> https://issues.apache.org/jira/browse/KAFKA-6607 Lag will never be
> reported as zero, because of the tailing transactional markers.
>
>
>
> The number of stored messages in a partition are not exposed in Kafka
> and I am not aware
Hi,
We are using Kafka Streams 2.2.1 and Kafka 2.2.0, and we noticed that the
end offset number is larger than the numbers of events sent to a topic if
we set *processing guarantee* as *exactly once* in a Kafka Streams app.
For example, if we send 2615 events to an empty topic, we expect the end
