来自 Kafka Producer 的控制台消息过多

2024-03-18

如何控制 Kafka 生产者或消费者的控制台日志记录级别?我在 Scala 中使用 Kafka 0.9 API。

每次send on the KafkaProducer被调用时,控制台给出如下输出。这是否表明我没有KafkaProducer设置正确,而不仅仅是过度记录的问题?

17:52:21.236 [pool-10-thread-7] INFO  o.a.k.c.producer.ProducerConfig - ProducerConfig values: 
compression.type = none
metric.reporters = []
metadata.max.age.ms = 300000
.
.
.
17:52:21.279 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bufferpool-wait-time
17:52:21.280 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name buffer-exhausted-records
17:52:21.369 [pool-10-thread-7] DEBUG org.apache.kafka.clients.Metadata - Updated cluster metadata version 1 to Cluster(nodes = [Node(-1, localhost, 9092)], partitions = [])
17:52:21.369 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-closed:client-id-producer-2
17:52:21.369 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name connections-created:client-id-producer-2
17:52:21.370 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent-received:client-id-producer-2
17:52:21.370 [pool-10-thread-7] DEBUG o.a.kafka.common.metrics.Metrics - Added sensor with name bytes-sent:client-id-producer-2
.
.

里面有日志配置propertiesKafka 服务器和 Zookeeper 查看的文件,但我假设这些不会影响 Kafka 客户端。更改这些文件中的一些日志配置,并重新启动 Kafka 服务器和 Zookeeper 以便重新加载这些文件,并没有解决问题。

谢谢


在 logback.xml 中添加名称为 org.apache.kafka 的记录器

<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
    <layout class="ch.qos.logback.classic.PatternLayout">
        <Pattern>
            %d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n
        </Pattern>
    </layout>
</appender>

<logger name="org.apache.kafka" level="warn">
    <appender-ref ref="STDOUT" />
</logger>


<root level="info">
    <appender-ref ref="STDOUT" />
</root>
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

来自 Kafka Producer 的控制台消息过多 的相关文章

随机推荐

  • 猫鼬预保存和验证之间的区别?什么时候使用哪一个?

    目前我正在使用pre save 进行验证 UserSchema pre save true function next done var self this in case inside a callback var msg helper
  • Angular 4 材质是否像 bootstrap 一样响应式?

    我正在使用 Angular 4 开始一个新项目 需要创建响应灵敏且令人愉悦的用户界面 bootstrap 为您提供响应能力 但没有物质感 棱角分明的材质提供了良好的 UI 体验https material angular io https
  • 防止箭头键更改选定的单选按钮

    我有几个单选按钮 我想阻止按下向上 向下箭头键来更改选定的单选按钮 如果您选择其中一个单选按钮 然后按向上 向下箭头键 它将选择上一个或下一个单选按钮 相反 我希望选择保持不变 为此我可以使用event preventDefault 在某些
  • Jgrid 生成 XML 时出现问题

    我正在使用 Jgrid 我像我们大多数人一样使用 Xml 将数据注入到网格中 我想要批量更新数据库 我的要求是 当我单击 保存更改 时 它会生成当前 更新的 网格数据的 Xml 那么 我如何生成Jgrid数据的Xml 请帮忙 这是代码
  • C++ 模板:返回 list::iterator

    我怎样才能使下面的代码工作 在编译过程中 我收到一条错误消息 告诉我searchForResource函数没有返回类型 template
  • 为什么我的 UILabel 不显示 NSInteger

    我有一个 ViewController 和 GameController 类 它是 NSObject 的子类 视图控制器有一个链接到它的按钮 并触发一个初始化 GameController 类的 IBAction 在 GameControl
  • 剪切背景以露出下面的图层

    有没有办法剪切 div 背景以暴露下面的图层 就像这样 to this 欢迎任何前沿的 CSS 规则 UPDATE 好的 我做了一个示例代码 http jsfiddle net coma 9ae7g 1 http jsfiddle net
  • 创建新文件时,vscode 让我选择一个编辑器

    When creating a new file vscode let me select an editor It hasn t do so and I don t want to choose one because I only us
  • 我应该如何处理 Perl 中不再使用的对象?

    我正在编写一个链接到外部资源的类 其中一种方法是破坏外部资源的删除方法 不应对该对象进行进一步的方法调用 我正在考虑设置一个标志 如果设置了标志 那么就会在所有方法中死亡 但是有没有更好 更简单的方法呢 也许涉及破坏 到目前为止 我真的很喜
  • Android Studio:“libpng 警告:iCCP:无法识别已编辑的已知 sRGB 配置文件”

    我花了几个小时试图解决这个问题 app mergeDebugResources AAPT err 927129865 C Users Will AndroidStudioProjects Splitter2 app build interm
  • 从两个绝对路径获取相对路径

    我有两个绝对文件系统路径 A 和 B 并且我想生成第三个文件系统路径来表示 A 相对于 B 使用案例 管理播放列表的媒体播放器 用户将文件添加到播放列表 新文件路径已添加到播放列表相对于播放列表路径 将来 整个音乐目录 包括播放列表 都会转
  • ANGULAR 2 - 组件共享数据服务

    这真的让我很头疼 我有一个不错的小应用程序 使用 Firebase 和 Angular 2 设置社交登录 一切都应该是实时的 基本上 当用户通过 Facebook 登录时 我希望将他们的个人信息传递到服务并存储为 Observable 并立
  • 如何在Python中的一个图形上绘制多个kdeplot

    我有以下数据 name val G Kittle 4 0 G Kittle 10 0 D Hopkins 3 0 L Fitzgerald 6 0 C Kupp 18 0 R Woods 21 0 N Harry 7 0 S Michel
  • Angular:创建 Angular 项目时出现新错误

    我使用时遇到此错误ng 新项目名称 发现无效的配置文件 angular json 请在运行命令之前删除该文件 我收到此错误 我不知道如何获得解决方案 我卸载了 angular cli 并再次安装 npm clean 缓存也不起作用 我不知道
  • 持续监听TCP端口

    我编写了一个能够通过 TCP 协议从端口接收数据的代码 我每 15 分钟从 ESP8266 接收一次数据 然后 ESP 进入深度睡眠模式 如何改变它才能使其持续工作 我想在 while 循环中创建一个新连接 但它不起作用 My code i
  • 如何在调用任何 url 时提供 ntlm 身份验证?

    我有一个使用 ntlm Windows 集成身份验证 进行身份验证的托管 URL 我在 windows 上使用 java 1 8 URL url new URL someUrl HttpURLConnection con HttpURLCo
  • 如果小程序在浏览器的 JRE 中运行,为什么机器上还需要 JRE?

    Applet 在浏览器的 JRE 中运行 这是否意味着您不必在计算机上安装 JRE 即可运行小程序 浏览器的 JVM is您计算机上安装的 JRE 浏览器通常不会附带自己的浏览器 它们只是使用您系统上已安装的任何浏览器 也许您混淆了 Jav
  • Angular 9 SSR 404 未找到带有状态代码的页面

    我正在使用 Angular 9 和 SSR 现在正在尝试获取 404 页面 它与客户端成功合作 但状态始终为 200 Ok 当我尝试使用 Angular ssr 时 它也显示 200 是状态代码 我的 Angular 路由器已成功传递到 4
  • 如何在Pycharm中暂停程序执行(暂停按钮不起作用)?

    在 Pycharm 5 0 4 中调试我的 Python 3 5 程序时 我试图按下暂停按钮来查找程序挂起的原因 位置 可以在 Visual Studio 中完成 但是 什么也没有发生 暂停按钮不会变成灰色 恢复按钮保持灰色 并且在调试器工
  • 来自 Kafka Producer 的控制台消息过多

    如何控制 Kafka 生产者或消费者的控制台日志记录级别 我在 Scala 中使用 Kafka 0 9 API 每次send on the KafkaProducer被调用时 控制台给出如下输出 这是否表明我没有KafkaProducer设