[ 
https://issues.apache.org/jira/browse/KAFKA-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16017556#comment-16017556
 ] 

Vahid Hashemian commented on KAFKA-5278:
----------------------------------------

Looks like the issue reported here is a subset of 
[KAFKA-3982|https://issues.apache.org/jira/browse/KAFKA-3982].
Plus, the correct syntax for providing additional properties directly in the 
command line is {{--consumer-propert}}, not {{--property}}.

> 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
>            Assignee: huxi
>            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}
> Without either, the output is
> {noformat}
> $ kafka-console-consumer --bootstrap-server localhost:9092 --from-beginning 
> --topic TEST1
> ?
>       ?
> ?
> |
> @
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to