【Kafka】Kafka动态调整日志级别Log4jController

1.概述

翻译：Dynamically Adjust Log Levels in Connect

2.动机

Kafka Connect不提供一个开箱即用的工具来更改日志级别。在调试连接器或Connect框架时，必须更新log4j。属性文件，并重新启动worker以查看新的日志。在大多数情况下，这是很麻烦的，并且重新启动worker有时会通过重置内部状态来隐藏bug。

3. 修改建议

Kafka代理目前有一个通过mbean调整日志级别的工具。这是一个scala实用程序，我们将用Java重写它，然后转移到Kafka -clients包中，使用这个实用程序在Kafka broker和Connect worker中初始化JMX接口。

4.公共接口

我们建议添加以下log4j controller:

public