kafka-console-consumer.sh¶

用法:

$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic afei [--group groupName] [--partition 目标分区]

这个命令后面还可带很多参数:

--key-deserializer：指定key的反序列化方式，默认是 org.apache.kafka.common.serialization.StringDeserializer
--value-deserializer：指定value的反序列化方式，默认是 org.apache.kafka.common.serialization.StringDeserializer
--from-beginning：从最早的消息开始消费，默认是从最新消息开始消费。
--offset： 从指定的消息位置开始消费，如果设置了这个参数，还需要带上--partition。
    否则会提示：The partition is required when offset is specified.
--timeout-ms：当消费者在这个参数指定时间间隔内没有收到消息就会推出，并抛出异常：kafka.consumer.ConsumerTimeoutException。
--whitelist：接收的topic白名单集合，和--topic二者取其一。例如：
    --whitelist "afei.*"（以afei开头的topic）
    --whitelist "afei"（指定afei这个topic）
    --whitelist "afei|fly"（指定afei或者fly这两个topic）
--blacklist: 和whitelist用法类似。