[ 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)