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 ?

Reply via email to