pls help We have 2 kafka topic. I want copy 10 message from beginning from topic1 to topic2. I`m try do it with kafka-console-consumer and kafka-console-producer First i save 10 message from top...

I need to produce batch messages to Kafka so I have a file that I feed kafkacat: kafkacat -b localhost:9092 -t <my_topic> -T -P -l /tmp/msgs The content of /tmp/msgs is as follows -H "id=...

I want to count the number of messages in a given Kafka topic between two timestamps. I tried doing this using kafkacat, using the following command: # START_DATE = 01.04.2022 02:00:00Z # END_DATE ...

We have following kafka-ssh-tunneling setup. ssh -N $JUMPHOST -L 2181:w.x.y.z:2181 -L 9092:a.b.c.d:9092 -L 9091:e.e.f.f:9092 broker IP is a.b.c.d , There is local lo0 device alias with same IP add...

I am looking for a way to delete a topic or all its messages using kafkacat. Is it possible or the only way is through the script listed here? bin/kafka-topics.sh --zookeeper localhost:2181 --dele...

In trying to use kafkacat with message hub, I've used the following: kafkacat -X client.id=xxxxx \ -X sasl.jaas.config='org.apache.kafka.common.security.plain.PlainLoginModule required username="x...

I am trying to install kafkaCat tool in windows machine. While doing a quick build by running ./bootstrap.sh, I am getting following error: $ ./bootstrap.sh Directory librdkafka already exists, no...

I'm playing around with Kafka and using my own local single instance of zookeeper + kafka and running into this error that I don't seem to understand how to resolve. I started a simple server per ...