Hello Kafka!
I'm using Flink with a Kafka and seeing an edge case that I'm hoping to get
some help to find the source code that would explain!
In the Flink setup, I have a transactional producer that's regularly committing
transactions with a consistent transactional ID. But all these transacti
Hello,
Several things need to be checked here:
1) Is your group id correct? Does that exist and it's version is
sufficiently new that it does not store metadata on ZK but on Kafka?
2) Is the bootstrap server list correct? Is that IP reachable.
On Wed, Nov 17, 2021 at 12:24 AM wan...@emrubik.co
Hi guys,
It seems the secure operation of a Kafka broker is very simple..but no for
me: it is very hard.
I hope in your help to solve my problem.
I want to show the steps to reproduce my error:
I generate CA and certificates and I store in a dir: /home/kafka/ssl.
I download and untar the
sorry , the picture is not displayed
From: wan...@emrubik.com
Date: 2021-11-17 16:10
To: users
Subject: Hi Team,
Hi Team,
I want obtain consumer group information through the Kafka JAVA API ，As shown
in figure
Properties properties = new Properties();
properties.put(Commo
Hi Team,
I want obtain consumer group information through the Kafka JAVA API ，As shown
in figure
Properties properties = new Properties();
properties.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG,
"10.127.16.2:9092");
try {
String groupId = "gwdp-hdb-c
