librdkafka自定义日志回调中fac参数的作用及相关文档查询
librdkafka 日志回调
fac 参数相关说明 rd_kafka_conf_set_log_cb() 回调函数中的fac参数全称是日志功能模块标识,作用是标记当前日志由librdkafka内部哪个子模块输出,方便开发者按模块分类、过滤日志。
librdkafka没有对外发布官方的fac取值对照文档,所有取值都是源码中定义的字符串常量,常见取值对应的模块含义如下:
FAIL:故障处理模块,对应连接断开、请求超时、权限校验失败等严重错误相关日志BGQUEUE:后台任务队列模块,对应后台线程的任务入队出队、队列积压、队列生命周期相关日志PRODUCE:消息生产模块,对应生产请求发送、消息批量打包、投递结果回调相关日志CONSUME:消息消费模块,对应消息拉取、报文解析、offset提交相关日志TOPIC:主题元数据模块,对应主题查询、元数据更新、分区分配相关日志BROKER:Broker交互模块,对应节点连接建立、心跳上报、节点状态变更相关日志CONF:配置管理模块,对应配置项校验、配置生效、配置变更相关日志SECURITY:安全模块,对应SSL/TLS握手、SASL认证、权限校验相关日志
你可以在日志回调中直接根据fac的取值做日志过滤,比如不需要后台队列的低级别调试日志,只要判断fac == "BGQUEUE"且日志级别低于WARNING就直接丢弃即可。
内容的提问来源于stack exchange,提问作者Yusup Badiev
相关产品推荐
相关产品推荐

