2019独角兽企业重金招聘Python工程师标准>>>

root@ocdata07 bin]# ./kafka-console-consumer.sh
The console consumer is a tool that reads data from Kafka and outputs it to standard output.
Option                                  Description                            
------                                  -----------                            
--blacklist <blacklist>                 Blacklist of topics to exclude from    
                                          consumption.                         
--consumer.config <config file>         Consumer config properties file.       
--csv-reporter-enabled                  If set, the CSV metrics reporter will  
                                          be enabled                           
--delete-consumer-offsets               If specified, the consumer path in     
                                          zookeeper is deleted when starting up
--formatter <class>                     The name of a class to use for         
                                          formatting kafka messages for        
                                          display. (default: kafka.tools.      
                                          DefaultMessageFormatter)             
--from-beginning                        If the consumer does not already have  
                                          an established offset to consume     
                                          from, start with the earliest        
                                          message present in the log rather    
                                          than the latest message.             
--max-messages <Integer: num_messages>  The maximum number of messages to      
                                          consume before exiting. If not set,  
                                          consumption is continual.            
--metrics-dir <metrics dictory>         If csv-reporter-enable is set, and     
                                          this parameter isset, the csv        
                                          metrics will be outputed here        
--property <prop>                                                              
--skip-message-on-error                 If there is an error when processing a
                                          message, skip it instead of halt.    
--topic <topic>                         The topic id to consume on.            
--whitelist <whitelist>                 Whitelist of topics to include for     
                                          consumption.                         
--zookeeper <urls>                      REQUIRED: The connection string for    
                                          the zookeeper connection in the form
                                          host:port. Multiple URLS can be      
                                          given to allow fail-over.

因此要同时启动 多个不同组的消费者,要么指定不同的配置文件,要么设置不同的property

不过设置consumer.config 的试过了 --可以用

但是property的只是在java api中用过 因此我感觉这里也可以用(猜想)

转载于:https://my.oschina.net/u/2329222/blog/479463

kafka消费者命令行的使用方法相关推荐

  1. Kafka 生产者、消费者命令行操作

    Kafka 生产者.消费者命令行操作 1.查看操作生产者命令参数 bin/kafka-console-producer.sh 参数 --bootstrap-server <String: ser ...

  2. python 命令行参数-Python 获得命令行参数的方法(推荐)

    本篇将介绍python中sys, getopt模块处理命令行参数 如果想对python脚本传参数,python中对应的argc, argv(c语言的命令行参数)是什么呢? 需要模块:sys 参数个数: ...

  3. VC6命令行编译工程方法

    VC6命令行编译工程方法 昨天下载一个界面库wxWidgets,编译里面的库很痛苦,有好几个工程,我的在一边等待,痛苦!!于是上网找到命令行编译的方法,可以写一个批处理文件,呵呵,想起以前经理编译工程 ...

  4. kafka _命令行操作

    kafka _命令行操作 #启动zk zkServer.start #启动kafka kafka-server-start.sh -daemon /opt/kafka/config/server.pr ...

  5. 打开计算机管理窗口命令,Win7如何打开命令行窗口?打开命令行窗口的方法

    有时我们会用到命令行工具,这时就需要打开电脑的命令行窗口,也就是Dos工具,然后再这个命令行窗口中输入可执行的命令完成我们想要的操作,比如打开一个文件夹或者删除文件等.那么Win7如何打开命令行窗口呢 ...

  6. Python命令行清屏方法

    Python命令行清屏方法 命令: >>> import os  >>> os.system("clear") 运行结果:

  7. linux命令图片,使用Linux命令行查看图像的方法有哪些

    今天小编要跟大家分享的文章是关于使用Linux命令行查看图像的方法有哪些?在 Linux 中有很多 GUI 应用程序可以查看图像,但是这对经常使用命令行来工作的人可能会觉得很繁琐.今天小编要为大家介绍 ...

  8. Ubuntu下命令行加速、终端加速、命令行代理的方法/proxychains安装与使用

    Ubuntu下命令行加速.终端加速.命令行代理的方法/使用proxychains 前提:已经安装并配置好代理/FQ工具. 实现方法:通过安装配置proxychains4实现,即是将任何程序和代理工具的 ...

  9. Android命令行启动应用方法

    Android命令行启动程序正确使用技巧解析 Android程序启动的方式除了使用界面方式进行启动之外,还能通过命令行启动.那么就让我们大家一起来看看Android命令行启动程序的具体操作方法. An ...

最新文章

  1. 【Pix4d精品教程】大疆精灵4A无人机航空摄影测量外业数据采集完整操作流程
  2. html不支持ie7,解决IE6/IE7/IE8不支持before,after问题
  3. word-break 对一个字符串根据给出的字典判断是否可以根据字典切分(DP问题)
  4. 下列服务使用的默认端口:ftp,ssh,telnet,dhcp,mail,pop3,smtp,dns,http,sm
  5. 【maven】maven dependencyManagement 锁定Jar包版本
  6. maven命令-P 参数引发的思考
  7. Dll注入技术之驱动注入
  8. K3 工业单据的对应相关表作用
  9. FFmpeg 内容介绍 音视频解码和播放
  10. java nio为什么是非阻塞_Java nio都是非阻塞IO么?并非如此
  11. 网上免费打电话和国际长途
  12. 高德h5定位误差_高德地图定位JS API不准确问题
  13. 书籍特别推荐:2018-06薛兆丰经济学讲义+魔鬼经济学(四本)
  14. java之xml进阶教程——使用castor框架
  15. macOS:自从 11.0.1 Big Sur 后,时间机器功能的变化
  16. 值得你收藏的几个实用识别图片文字软件都在这
  17. 必应输入法的分析与用户需求调查报告
  18. 扩展DailyRollingFileAppender使其支持限定日志文件的数量
  19. JAVA计算机毕业设计读书网络社区设计Mybatis+系统+数据库+调试部署
  20. python-docx在word中表格添加表格

热门文章

  1. 关于 Workbench中 pk,nn,uq,bin,un,zf,ai 的解释
  2. docker的学习总结
  3. tkinter 10 messagebox 弹窗
  4. #180111mysql启动错误
  5. ios swift ios8 模糊
  6. Centos6.5子域名绑定子目录
  7. Git中的AutoCRLF与SafeCRLF换行符问题
  8. 打开组策略时提示inetres.admx管理模板解析出错解决方法
  9. HTML5中figure标签使用实例
  10. HTML DOM 节点