Yeva Byzek created KAFKA-5278: --------------------------------- Summary: kafka-console-consumer: `--value-deserializer` is not working but `--property value.deserializer` does Key: KAFKA-5278 URL: https://issues.apache.org/jira/browse/KAFKA-5278 Project: Kafka Issue Type: Bug Components: clients Affects Versions: 0.10.2.1 Reporter: Yeva Byzek Priority: Minor
kafka-console-consumer: {{--value-deserializer}} is not working but {{--property value.deserializer}} is working 1. Does not work {noformat} $ kafka-console-consumer --bootstrap-server localhost:9092 --from-beginning --topic TEST1 --value-deserializer org.apache.kafka.common.serialization.LongDeserializer [2017-05-18 13:09:41,745] ERROR Error processing message, terminating consumer process: (kafka.tools.ConsoleConsumer$) java.lang.ClassCastException: java.lang.Long cannot be cast to [B at kafka.consumer.NewShinyConsumer.receive(BaseConsumer.scala:100) at kafka.tools.ConsoleConsumer$.process(ConsoleConsumer.scala:120) at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:75) at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:50) at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala) Processed a total of 0 messages {noformat} 2. Does work {noformat} $ kafka-console-consumer --bootstrap-server localhost:9092 --from-beginning --topic TEST1 --property value.deserializer=org.apache.kafka.common.serialization.LongDeserializer 1000 2500 2000 5500 8000 {noformat} -- This message was sent by Atlassian JIRA (v6.3.15#6346)