Hi all,
What are the situations in which the Kafka consumer metric
`records-lag-max` would return NaN? Please point me to documentation if
that exists. Thanks!
Best,
Mason
Hi David,
Glad that my old post helps you! :)
Thank you.
Luke
On Sat, Sep 11, 2021 at 6:39 AM David Ballano Fernandez <
dfernan...@demonware.net> wrote:
> oops, I think I found my answer in a few mails below:
> and if i am not mistaken that is why my only consumer is only writing to
> one partit
oops, I think I found my answer in a few mails below:
and if i am not mistaken that is why my only consumer is only writing to
one partition out of 50.
Hi Michał,
Internally, Kafka uses "*consumer group ID*" as the key to decide which
__consumer_offsets partition to be used.
The code is like this:
Hi all,
I am running kafka 2.7 in the cluster and only has one consumer reading
from it multiple topics.
I just find out looking at the __consumer_offset topic that only one
partition of that topic is being written to?
Is that normal?
thank you!
Hi team,
I have used kafka producer InitTransactions in my project, but I got
timeout error.
Error: producer InitTransactions {"PID": 6041, "Service": "main",
"error": "Failed to initialize Producer ID: Local: Timed out"}
Here how I have created a producer object.
p, err := confluentkafka.NewP
Hi Konstantine,
Thanks for that; I can get to the docs now.
I've validated the release by doing the following
- built from source
- ran all unit tests
- verified all checksums and signatures
- spot-checked the Javadoc
- worked through the quick start
- worked through the Kafka
Hello Kafka users, developers and client-developers,
This is the first candidate for release of Apache Kafka 2.8.1.
Apache Kafka 2.8.1 is a bugfix release and fixes 49 issues since the 2.8.0
release. Please see the release notes for more information.
Release notes for the 2.8.1 release:
https://
