ERROR Error when sending message to topic

ERROR Error when sending message to topic

While producing message in kafka, i am getting the following error :
$ bin/kafka-console-producer.sh –broker-list localhost:9092 –topic nil_PF1_P1
hi
hello

[2016-07-19 17:06:34,542] ERROR Error when sending message to … Read more

Fluentd vs Kafka

Fluentd vs Kafka

The use case is this:
I’ve several java applications running which all have to interact with different (each one has a specific target) elasticsearch indices. For instance an application A uses the … Read more

Kafka Consumer get key value pair

Kafka Consumer get key value pair

I’m currently working with Kafka and Flink, I have kafka running in my local PC and I created a topic that is being consumed.
Desktop\kafka\bin\windowskafka-console-consumer.bat –zookeeper localhost:2181 -topic … Read more

kafka get partition count for a topic

kafka get partition count for a topic

How can I get number of partitions for any kafka topic from the code. I have researched many links but none seem to work.
Mentioning a few:
http://grokbase.com/t/kafka/users/148132gdzk/find-topic-partition-count-through-simpleclient-api… Read more