Kafka常⽤命令之kafka-console-consumer.sh
kafka-console-consumer.sh 脚本是⼀个简易的消费者控制台。该 shell 脚本的功能通过调⽤ ls 包下的ConsoleConsumer类，并将提供的命令⾏参数全部传给该类实现。
1.⼿动插⼊数据
kafka-console-producer.sh --broker-list 192.168.104.91:9092,192.168.104.92:9092,192.168.104.93:9092 --topic capture_test
2. 消息消费
bin/kafka-console-consumer.sh --bootstrap-server 192.168.104.91:9092,192.168.104.92:9092,192.168.104.93:9092 --topic topicName
bin/kafka-console-consumer.sh  --zookeeper 192.168.104.91:2181,192.168.104.92:2181,192.168.104.93:2181 --topic topicName
表⽰从 latest 位移位置开始消费该主题的所有分区消息，即仅消费正在写⼊的消息。
3.从开始位置消费
bin/kafka-console-consumer.sh --bootstrap-server 192.168.104.91:9092,192.168.104.92:9092,192.168.104.93:9092 --from-beginning --topic topicName
bin/kafka-console-consumer.sh --zookeeper 192.168.104.91:2181,192.168.104.92:2181,192.168.104.93:2181 --from-beginning --topic topicName
4.显⽰key消费
bin/kafka-console-consumer.sh --bootstrap-server 192.168.104.91:9092,192.168.104.92:9092,192.168.104.93:9092 --property print.key=true --topic topicName
bin/kafka-console-consumer.sh --zookeeper 192.168.104.91:2181,192.168.104.92:2181,192.168.104.93:2181 --property print.key=true --topic topicName
消费出的消息结果将打印出消息体的 key 和 value。
参数值类型说明有效值
--topic string被消费的topic
--whitelist string正则表达式，指定要包含以供使⽤的主题的⽩名单
--partition integer指定分区
除⾮指定’–offset’，否则从分区结束(latest)开始消费
--offset string执⾏消费的起始offset位置
默认值:latest latest earliest <offset>
--consumer-property string将⽤户定义的属性以key=value的形式传递给使⽤者--fig string消费者配置属性⽂件
请注意，[consumer-property]优先于此配置
--formatter string⽤于格式化kafka消息以供显⽰的类的名称
默认值:ls.ls.ls.ls.ls.ChecksumMessageFormatter
-
-property string初始化消息格式化程序的属性print.timestamp=true|false
print.key=true|false
print.value=true|false
key.separator=<key.separator>
line.separator=<line.separator>
key.deserializer=<key.deserializer> value.deserializer=<value.deserializer>
--from-beginning从存在的最早消息开始，⽽不是从最新消息开始--max-messages integer消费的最⼤数据量，若不指定，则持续消费下去--timeout-ms integer在指定时间间隔内没有消息可⽤时退出
--skip-message-on-error如果处理消息时出错，请跳过它⽽不是暂停
--bootstrap-server string必需(除⾮使⽤旧版本的消费者)，要连接的服务器--key-deserializer string
console命令大全
--value-deserializer string
--enable-systest-events 除记录消费的消息外，还记录消费者的⽣命周期(⽤于系统测试)
--isolation-level string 设置为read_committed以过滤掉未提交的事务性消息设置为read_uncommitted以读取所有消息
默认值:read_uncommitted
--group string指定消费者所属组的ID
--blacklist string要从消费中排除的主题⿊名单
--blacklist string要从消费中排除的主题⿊名单
--csv-reporter-enabled如果设置，将启⽤csv metrics报告器
--delete-consumer-offsets如果指定，则启动时删除zookeeper中的消费者信息--metrics-dir string输出csv度量值
需与[csv-reporter-enable]配合使⽤
--zookeeper string 必需(仅当使⽤旧的使⽤者时)连接zookeeper的字符串。可以给出多个URL以允许故障转移
参数值类型说明有效值

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。