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 w
: Port already in use Exception after
enable JMX
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-conso
ersion ?
>
> 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
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
e
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
own by the agent : java.rmi.server.ExportException:
Port already in use: 9988; nested exception is:
java.net.BindException: Address already in use (Bind failed)
wangl...@geekplus.com.cn
This e-mail and any files transmitted with it are for the sole use of the
intended recipient(
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
M sunil chaudhari <
> sunilmchaudhar...@gmail.com>
> wrote:
>
> > Hi,
> > I just enlabled the Jmx port in kafka broker.
> > Since then I am not able to run utilities under /bin
> > Example when I run
> > ./kafka-topics.sh —create
> > Then it
t; Example when I run
> ./kafka-topics.sh —create
> Then it throws bindException port already in use 9099
>
> Before it was running.
> Same thing happening for perf test utilities under /bin.
>
> Please help. How can i run those utilities with JMx port ON.
>
> Regards,
> Sunil.
>
Hi,
I just enlabled the Jmx port in kafka broker.
Since then I am not able to run utilities under /bin
Example when I run
./kafka-topics.sh —create
Then it throws bindException port already in use 9099
Before it was running.
Same thing happening for perf test utilities under /bin
1-test.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/kafka-clients-0.8.2.1.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/log4j-1.2.16.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/lz4-1.2.0.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/metrics-core-2.2.0.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/scala-library-2.
.1/bin/../libs/slf4j-log4j12-1.6.1.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/snappy-java-1.1.1.6.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/zkclient-0.3.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/zookeeper-3.4.6.jar:/opt/kafka_2.10-0.8.2.1/bin/../core/build/libs/kafka_2.10*.jar
> >> > kafka.
../libs/snappy-java-1.1.1.6.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/zkclient-0.3.jar:/opt/kafka_2.10-0.8.2.1/bin/../libs/zookeeper-3.4.6.jar:/opt/kafka_2.10-0.8.2.1/bin/../core/build/libs/kafka_2.10*.jar
>> > kafka.Kafka /opt/kafka_2.10-0.8.2.1/config/server.properties*
>> >
>>
10-0.8.2.1/bin/../libs/zookeeper-3.4.6.jar:/opt/kafka_2.10-0.8.2.1/bin/../core/build/libs/kafka_2.10*.jar
> > kafka.Kafka /opt/kafka_2.10-0.8.2.1/config/server.properties*
> >
> >
> > *[achan@server1 ~]$ sudo /opt/kafka_2.10-0.8.2.1/bin/kafka-topics.sh
>
–replica 0 –topic test.logs*
> *[sudo] password for achan:*
> *Error: Exception thrown by the agent : java.rmi.server.ExportException:
> Port already in use: 9994; nested exception is:*
> * java.net.BindException: Address already in use*
>
> I have pretty much the manila kakfa-run-class.sh except i added t
test.logs*
*[sudo] password for achan:*
*Error: Exception thrown by the agent : java.rmi.server.ExportException:
Port already in use: 9994; nested exception is:*
* java.net.BindException: Address already in use*
I have pretty much the manila kakfa-run-class.sh except i added the
following
*export JMX_PORT
16 matches
Mail list logo