kafka消费者命令行的使用方法
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消费者命令行的使用方法相关推荐
- Kafka 生产者、消费者命令行操作
Kafka 生产者.消费者命令行操作 1.查看操作生产者命令参数 bin/kafka-console-producer.sh 参数 --bootstrap-server <String: ser ...
- python 命令行参数-Python 获得命令行参数的方法(推荐)
本篇将介绍python中sys, getopt模块处理命令行参数 如果想对python脚本传参数,python中对应的argc, argv(c语言的命令行参数)是什么呢? 需要模块:sys 参数个数: ...
- VC6命令行编译工程方法
VC6命令行编译工程方法 昨天下载一个界面库wxWidgets,编译里面的库很痛苦,有好几个工程,我的在一边等待,痛苦!!于是上网找到命令行编译的方法,可以写一个批处理文件,呵呵,想起以前经理编译工程 ...
- kafka _命令行操作
kafka _命令行操作 #启动zk zkServer.start #启动kafka kafka-server-start.sh -daemon /opt/kafka/config/server.pr ...
- 打开计算机管理窗口命令,Win7如何打开命令行窗口?打开命令行窗口的方法
有时我们会用到命令行工具,这时就需要打开电脑的命令行窗口,也就是Dos工具,然后再这个命令行窗口中输入可执行的命令完成我们想要的操作,比如打开一个文件夹或者删除文件等.那么Win7如何打开命令行窗口呢 ...
- Python命令行清屏方法
Python命令行清屏方法 命令: >>> import os >>> os.system("clear") 运行结果:
- linux命令图片,使用Linux命令行查看图像的方法有哪些
今天小编要跟大家分享的文章是关于使用Linux命令行查看图像的方法有哪些?在 Linux 中有很多 GUI 应用程序可以查看图像,但是这对经常使用命令行来工作的人可能会觉得很繁琐.今天小编要为大家介绍 ...
- Ubuntu下命令行加速、终端加速、命令行代理的方法/proxychains安装与使用
Ubuntu下命令行加速.终端加速.命令行代理的方法/使用proxychains 前提:已经安装并配置好代理/FQ工具. 实现方法:通过安装配置proxychains4实现,即是将任何程序和代理工具的 ...
- Android命令行启动应用方法
Android命令行启动程序正确使用技巧解析 Android程序启动的方式除了使用界面方式进行启动之外,还能通过命令行启动.那么就让我们大家一起来看看Android命令行启动程序的具体操作方法. An ...
最新文章
- 【Pix4d精品教程】大疆精灵4A无人机航空摄影测量外业数据采集完整操作流程
- html不支持ie7,解决IE6/IE7/IE8不支持before,after问题
- word-break 对一个字符串根据给出的字典判断是否可以根据字典切分(DP问题)
- 下列服务使用的默认端口:ftp,ssh,telnet,dhcp,mail,pop3,smtp,dns,http,sm
- 【maven】maven dependencyManagement 锁定Jar包版本
- maven命令-P 参数引发的思考
- Dll注入技术之驱动注入
- K3 工业单据的对应相关表作用
- FFmpeg 内容介绍 音视频解码和播放
- java nio为什么是非阻塞_Java nio都是非阻塞IO么?并非如此
- 网上免费打电话和国际长途
- 高德h5定位误差_高德地图定位JS API不准确问题
- 书籍特别推荐:2018-06薛兆丰经济学讲义+魔鬼经济学(四本)
- java之xml进阶教程——使用castor框架
- macOS:自从 11.0.1 Big Sur 后,时间机器功能的变化
- 值得你收藏的几个实用识别图片文字软件都在这
- 必应输入法的分析与用户需求调查报告
- 扩展DailyRollingFileAppender使其支持限定日志文件的数量
- JAVA计算机毕业设计读书网络社区设计Mybatis+系统+数据库+调试部署
- python-docx在word中表格添加表格