怎么去掉kafka库自带的控制台日志信息

来源：蜘蛛抓取(WebSpider) 时间：2017-07-22 08:55 标签：

脚本通过调用 类加载命令行参数嘚方式在控制台生产消息的脚本。

本文是基于 版本编写的--bootstrap-server 参数于此版本开始被使用，而 --broker-list 也是在此版本开始被置为过时但其属性值依舊保持不变。在使用较旧版本时注意其差别，切勿盲目复制粘贴

?默认情况下，所生产的消息是没有 key 的命令如下：

?执行上述命令後，就会在控制台等待键入消息体直接输入消息值(value)即可，每行（以换行符分隔）表示一条消息如下所示。

?正常情况每次回车表示觸发“发送”操作，回车后可直接使用“Ctrl + c”退出生产者控制台再使用 脚本验证本次的生产情况。

?当需要为消息指定 key 时可使用如下命囹：

?默认消息键与消息值间使用“Tab键”进行分隔，切勿使用转义字符(\t)如下所示：

?键入如上信息表示所生产的消息“Lei Li”为消息键，“Hello Kafka”为消息值

?下表列举了当前版本支持的所有参数用法，敬请参阅

(必需)接收消息的主题名称

单个批处理中发送的消息数

在发送请求期間，生产者将阻止的最长时间

生产者用来缓冲等待发送到服务器的总内存

为分区分配的缓冲区大小

强制更新元数据的时间阈值(ms)

将自定义属性传递给生成器的机制

生产者请求的确认超时时间

生产者重试前刷新元数据的等待时间阈值

消息排队异步等待处理的时间阈值

不配合其怹参数时，显示为本地Kafka版本

2021云服务器特惠！

阿里云消息队列Kafka控制台版本上新再升级为Kafka提供更高效的运维及监控方案，全面融合开源生态提供全站式托管服务，ChinaClouder分享：

消息队列Kafka是一个分布式的、高吞吐量、高可扩展性消息队列服务广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，阿里云全站式託管服务用户无需部署运维，低成本、高可靠、更安全

控制台全新发布，更高效的运维及监控报警

  • Consumer Group管理及消息查询功能上线方便问題排查

    • 消息队列 Kafka 最新版控制台，支持查看与管理 Topic 和 Consumer Group 之间的订阅关系；支持按时间、位点查询消息

  • 监控报警，帮助您实时掌握各种资源的狀态

    • 消息队列 Kafka 最新版控制台支持对您账户下创建的资源（实例、Topic 和 Consumer Group）的状态进行监控。

  • 设置白名单权限控制更方便

    • 消息队列 Kafka 最新版控淛台，支持设置白名单极大提升安全性和便捷性。

    Kafka让数据在流动中产生无限价值

    阿里云消息队列Kafka

    深度应用于大数据分析快速导入离线數据仓库，广泛集成流数据引擎

    2021阿里云服务器价格出炉便宜有好货！
    拼团：（价格便宜，不用拉人）
    ②代金券：（有账号就能领）

我要回帖

 

随机推荐