最近在对kafka客户端进行轻量级封装,使得其具有简单的权限控制功能,由于不能暴露任何关于brokerlist,zookeeperlist的信息给客户端,只是对于授权的key后进行正确构造即可。而由于kafka默认是输出了很多info日志,里面broker zookeeper主机/端口信息暴露无遗,于是简单设置下对应的Logger级别关闭即可:

static {
// 修改kafka日志输出级别
Logger.getLogger("kafka.client").setLevel(Level.OFF);
Logger.getLogger("kafka.producer").setLevel(Level.OFF);
Logger.getLogger("kafka.utils").setLevel(Level.OFF);
Logger.getLogger("kafka.consumer").setLevel(Level.OFF);
Logger.getLogger("kafka.network").setLevel(Level.OFF);
Logger.getLogger("org.apache.zookeeper").setLevel(Level.OFF);
}


当然, 如果是使用别的日志框架,目前还暂时没有做,主要考虑到大部分都是Log4j。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐