btw, one thing i noticed - the behavior when i used Confluent Kafka is different from what i see on Apache Kafka, with Confluent Kafka - i was able to see the messages on the console, also the command-line options seem to be different
On Wed, Dec 20, 2017 at 7:19 PM, sham singh <singh.shammi2...@gmail.com> wrote: > Hello - i'm using Kafka 0.10 & am trying to use the > kafka-console-consumer.sh to consume/display the messages produced by > kafka-producer-perf-test.sh > This seems to be working fine, except that the console is not displaying > the text produced. > > Command used : > > Console Producer : > > */usr/hdp/2.5.3.0-37/kafka/bin/kafka-producer-perf-test.sh --messages > 1000000 --message-size 1000 --topics mmtest --broker-list localhost:9092 > --threads 1 --compression-codec 3 --batch-size 10000* > > Console Consumer : > > */usr/hdp/2.5.3.0-37/kafka/bin/kafka-console-consumer.sh --new-consumer > --topic mmtest \* > *--bootstrap-server localhost:9092 \* > *--property print.key=true \* > * --property print.value=true \* > * --property > key.deserializer=org.apache.kafka.common.serialization.StringDeserializer \* > * --property > value.deserializer=org.apache.kafka.common.serialization.StringDeserializer > \* > > Any ideas on what need to be done to fix the issue ? > what should the De-serializer should be set to ? > >
