RE: kafka-console-consumer.sh: --bootstrap-server not apparently taken into account?

Please check what is configured in server.properties for below properties. Those properties cannot have localhost if your client process running on a different machine. listeners advertised.listeners -Original Message- From: Dumitru-Nicolae Marasoui Sent: Saturday, July 4, 2020 9:55

RE: How to Change number of partitions without Rolling restart?

Please execute by looping through your topic list. Change partition number based on your requirement. for topic in `kafka-topics --zookeeper localhost:2181 --list` ./bin/kafka-topics.sh --alter --zookeeper localhost:2181 --topic $topic --partition done -Original Message- From:

RE: Kafka Timeout Exception

Team, Could you please help on my below query? -Original Message- From: JOHN, BIBIN Sent: Monday, May 25, 2020 11:48 PM To: users@kafka.apache.org Subject: Kafka Timeout Exception *** Security Advisory: This Message Originated Outside of AT&T ***. Reference http://cso.att

Kafka Timeout Exception

Team, What happens when producer gets below timeout exception? Is that error saying those records will be ignored and will not send to kafka? org.apache.kafka.common.errors.TimeoutException: Expiring 22 record(s) for topic1-1: 30215 ms has passed since batch creation plus linger time org.apache

RE: Help with setting up Kafka Node

How are you starting it? -Original Message- From: i...@fluent-software.de Sent: Monday, April 20, 2020 11:56 AM To: users@kafka.apache.org Subject: AW: Help with setting up Kafka Node I can't see any errors. Changing the debug level to debug I got the following log: [2020-04-20 18:25

Adding additional nodes to Existing ZK cluster

Team, I currently have a 1 node ZK cluster and which is working fine. Now I want to add additional 2 more nodes to ZK cluster. Could you please provide best practice so I don't loose existing data? Thanks Bibin John

RE: kafka-run-class.sh kafka.tools.GetOffsetShell in SASL enabled cluster

Team, Could you please help on this? Thanks Bibin John From: JOHN, BIBIN Sent: Thursday, January 30, 2020 11:59 PM To: users@kafka.apache.org Subject: kafka-run-class.sh kafka.tools.GetOffsetShell in SASL enabled cluster Team, I am getting below error when try to use kafka-run-class.sh

kafka-run-class.sh kafka.tools.GetOffsetShell in SASL enabled cluster

Team, I am getting below error when try to use kafka-run-class.sh kafka.tools.GetOffsetShell in SASL enabled cluster. I set KAFKA_OPTS with path for jaas file. could you please help me what is reason for this? Kafka Version : 2.3.0 [2020-01-31 00:55:12,934] WARN [Consumer clientId=GetOffsetShe

RE: Kafka Broker leader change without effect

Producer request will not fail. Producer will fail based on acks and min.insync.replicas config parameters. -Original Message- From: Ryanne Dolan Sent: Thursday, January 16, 2020 10:52 AM To: Kafka Users Subject: Re: Kafka Broker leader change without effect Marco, the replication f

RE: JMX Metrics to display disk Usage

tory on disk. > From graphite, I sum that data per topic so I can see total disk usage > per topic across my cluster. > > -- Peter > > > On Jan 9, 2020, at 8:05 PM, JOHN, BIBIN wrote: > > > > Is there any metrics available to view disk usage in each > > bro

JMX Metrics to display disk Usage

Is there any metrics available to view disk usage in each broker/topic via JMX exporter? If yes, could you please send me details? Thanks

RE: java.net.BindException: Address already in use (Bind failed) with kafka-topics command

mirror maker process / it is a bug. netstat -an | wc -l Regards, Kalai On Thu, 9 Jan, 2020, 10:46 AM JOHN, BIBIN, wrote: > Could you please let me know why sometimes I am getting, below exception? > Cluster is up and running. Kafka and ZK is running in same server. We > also have jmx

java.net.BindException: Address already in use (Bind failed) with kafka-topics command

Could you please let me know why sometimes I am getting, below exception? Cluster is up and running. Kafka and ZK is running in same server. We also have jmx exporter configured for monitoring. kafka-topics --zookeeper localhost:2181 --list Error: Exception thrown by the agent : java.rmi.server.