Kafka常用命令之kafka-console-consumer.sh解读
更新时间：2023年03月07日 10:08:33 作者：Ernest.Wu
这篇文章主要介绍了Kafka常用命令之kafka-console-consumer.sh解读，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
kafka-console-consumer.sh解读
kafka-console-consumer.sh 脚本是一个简易的消费者控制台。
该 shell 脚本的功能通过调用 kafka.tools 包下的 ConsoleConsumer 类，并将提供的命令行参数全部传给该类实现。
- 注意：Kafka 从 2.2 版本开始将 kafka-topic.sh 脚本中的 −−zookeeper 参数标注为 “过时”，推荐使用 −−bootstrap-server 参数。
- 若读者依旧使用的是 2.1 及以下版本，请将下述的 --bootstrap-server 参数及其值手动替换为 --zookeeper zk1:2181,zk2:2181,zk:2181。
- 一定要注意两者参数值所指向的集群地址是不同的。
消息消费
bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --topic topicName
表示从 latest 位移位置开始消费该主题的所有分区消息，即仅消费正在写入的消息。
从开始位置消费
bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --from-beginning --topic topicName
表示从指定主题中有效的起始位移位置开始消费所有分区的消息。
显示key消费
bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --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的形式传递给使用者 | |
| --consumer.config | string | 消费者配置属性文件 请注意，[consumer-property]优先于此配置 | |
| --formatter | string | 用于格式化kafka消息以供显示的类的名称 默认值:kafka.tools.DefaultMessageFormatter | kafka.tools.DefaultMessageFormatter kafka.tools.LoggingMessageFormatter kafka.tools.NoOpMessageFormatter kafka.tools.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 | ||
| --value-deserializer | string | ||
| --enable-systest-events | 除记录消费的消息外，还记录消费者的生命周期 (用于系统测试) | ||
| --isolation-level | string | 设置为read_committed以过滤掉未提交的事务性消息 设置为read_uncommitted以读取所有消息 默认值:read_uncommitted | |
| --group | string | 指定消费者所属组的ID | |
| --blacklist | string | 要从消费中排除的主题黑名单 | |
| --csv-reporter-enabled | 如果设置，将启用csv metrics报告器 | ||
| --delete-consumer-offsets | 如果指定，则启动时删除zookeeper中的消费者信息 | ||
| --metrics-dir | string | 输出csv度量值 需与[csv-reporter-enable]配合使用 | |
| --zookeeper | string | 必需(仅当使用旧的使用者时)连接zookeeper的字符串。 可以给出多个URL以允许故障转移 |
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
这篇文章主要为大家详细介绍了Java实现邮件发送功能，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-08-08
Mockito是一个强大的mock工具，本文将重点讲述Mockito的基本使用及注意事项，以及Controller测试用例，本文通过示例代码给大家介绍的非常详细，需要的朋友参考下吧2021-07-07
这篇文章主要为大家详细介绍了Java实现学生信息管理系统,借助Array List，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-01-01
这篇文章主要介绍了Java实现QQ第三方登录的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-11-11
Mybatis Plus使用条件构造器增删改查功能的实现方法
这篇文章主要介绍了Mybatis-Plus使用条件构造器增删改查,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-05-05
Spring Security 基于URL的权限判断源码解析
这篇文章主要介绍了Spring Security 基于URL的权限判断问题，我们想要实现自己的基于请求Url的授权只需自定义一个 AccessDecisionManager即可，接下来跟随小编一起看看实现代码吧2021-12-12
这篇文章主要介绍了Java应用/JVM宕机排查步骤操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-09-09
本文详细介绍了使用Vue和SpringBoot实现token认证的方法,包括前后端交互流程、后端依赖导入、token工具类、拦截器、跨域处理、前端路由守卫、请求拦截器等内容,具有一定的参考价值,感兴趣的可以了解一下2024-10-10
这篇文章主要介绍了MyBatis中的mapper.xml配置,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧2024-01-01
这篇文章主要为大家详细介绍了如何简单实现Java通讯录系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-02-02
最新评论