Hi rohit，
Surely unset jmx report can solve my issue
Exit and login again not work.
But i can execute the consumer.sh on others hosts.
Thanks,
Lei
wangl...@geekplus.com.cn
From: rohit garg
Date: 2020-05-11 13:24
To: users
CC: wanglei2
Subject: Re: kafka-console-consumer.sh: Port already
bin/kafka-console-consumer.sh --bootstrap-server 172.19.78.32:9092 --topic
tapicName
I am using kafka_2.11-2.4.1
wangl...@geekplus.com.cn
From: manoj.agraw...@cognizant.com
Date: 2020-05-11 12:39
To: wangl...@geekplus.com.cn; users@kafka.apache.org
Subject: Re: kafka-console-consumer.sh: Po
There are two ways to solve this issue,
Exit and relogin again ,
Or again after broker is started , unset jmx port and you are good to go .
Thanks and Regards,
Rohit Garg
On Mon, May 11, 2020, 10:10 wrote:
> Please share the consumer.sh .
> Are you using Apache kafka and what version ?
>
> F
Please share the consumer.sh .
Are you using Apache kafka and what version ?
From: "wangl...@geekplus.com.cn"
Date: Sunday, May 10, 2020 at 9:38 PM
To: users
Cc: "Agrawal, Manoj (Cognizant)"
Subject: Re: Re: kafka-console-consumer.sh: Port already in use Exception after
enable JMX
[External]
Hi Manoj，
I have tried, not work.
When i changed to 9998, the consumer.sh tells me Port already in use: 9998
Thanks,
Lei
wangl...@geekplus.com.cn
From: manoj.agraw...@cognizant.com
Date: 2020-05-11 12:04
To: users@kafka.apache.org
Subject: Re: kafka-console-consumer.sh: Port already in
You can change jmx-port to any available port - 9992
On 5/10/20, 7:49 PM, "wangl...@geekplus.com.cn"
wrote:
[External]
Add JMX_PORT=9988 to kafka-run-class.sh to enable JMX
After execute bin/kafka-console-consumer.sh there‘s exception：
Error: Exception thrown by the agent
Add JMX_PORT=9988 to kafka-run-class.sh to enable JMX
After execute bin/kafka-console-consumer.sh there‘s exception：
Error: Exception thrown by the agent : java.rmi.server.ExportException: Port
already in use: 9988; nested exception is:
java.net.BindException: Address already in use
Hi,
I have a peculiar problem when using reactor-kafka client with
authentication and transactions enabled.
I get an exception:
org.apache.kafka.common.errors.TransactionalIdAuthorizationException:
Transactional Id authorization failed.
This happens while the client initializes the transactions
I will chip in my 2c here as we use open source Kafka stuff in production,
and we use some of the Confluent and community additions.
Thus far we have not paid for anything other than cloud metal.
The Confluent team seems super legit to me. They are making a lot of useful
stuff freely available to
Hello Friends,
I wrote into stackoverflow but also i am writing here,
I have couple of questions about window operation, grace period and late
events.
Could you please check my problem about group by with adding time field as
a key or window by and group by without time field ?
Here is detail e
10 matches
Mail list logo
