Hi,
I'm definitly no expert, but to me it sounds as not all your messages are
getting processed by the same consumer. Are you using the key `foo` for
partitioning? Is `baz` actually another key or is this mixup in your example
and `baz` is another value with key `foo`?
Hope you find a solution
> map ->
through. The through method has been deprecated and replaced by repartition.
I think there is definitely a way to do this using some "index" topics and the
streams API.
Hope this helps.
Chad
On Mon, Nov 15, 2021 at 7:06 AM Claudia Kesslau wrote:
> Hi Kafka commun
seems like
quite a common scenario but I could not find any solutions on the internet and
all solutions listed here do not seem good ones.
Thanks for your feedback.
Best,
Claudia Kesslau
Code Block 1:
___
Hi,
I tried to add a second listener to my kafka brokers running in docker like
this:
listeners=INTERNAL://{{getenv "KAFKA_SERVER_IP"}}:{{getenv "KAFKA_PORT"
"9092"}}, EXTERNAL://0.0.0.0:{{getenv "KAFKA_PORT_EXTERNAL" "9096"}}
listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
Hi,
I use https://github.com/prometheus/jmx_exporter for collecting broker metrics
and integrating them into prometheus.
Hope this helps.
Greetings,
Claudia
-Ursprüngliche Nachricht-
Von: Pushkar Deole
Gesendet: Mittwoch, 15. Juli 2020 09:07
An: users@kafka.apache.org
Betreff: Re: kaf
