[ 
https://issues.apache.org/jira/browse/KAFKA-4535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Xin updated KAFKA-4535:
-----------------------
           Labels: documentation  (was: )
    Fix Version/s: 0.10.1.1
           Status: Patch Available  (was: Open)

kafka-console-consumer.sh --bootstrap-server localhost:9092 \
            --topic streams-wordcount-Counts-changelog \
            --from-beginning \
            --formatter kafka.tools.DefaultMessageFormatter \
            --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.LongDeserializer  \
            --new-consumer

> http://kafka.apache.org/quickstart Step 8  missing  argument
> ------------------------------------------------------------
>
>                 Key: KAFKA-4535
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4535
>             Project: Kafka
>          Issue Type: Bug
>          Components: documentation
>    Affects Versions: 0.10.1.0
>            Reporter: Xin
>            Priority: Trivial
>              Labels: documentation
>             Fix For: 0.10.1.1
>
>
> Step 8: Use Kafka Streams to process data:
> > bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 \
>             --topic streams-wordcount-output \
>             --from-beginning \
>             --formatter kafka.tools.DefaultMessageFormatter \
>             --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.LongDeserializer
> ===> result:
> Missing required argument "[zookeeper]"
> the command  need "--new-consumer“



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to