我可以得到一个示例,将日志发布到kafka topic。我目前正在使用uber-go/zap logger和https://github.com/confluentinc/confluent-kafka-go进行发布。
发布于 2020-09-17 22:45:47
看看这个项目,它为Kafka提供了一个日志接收器:https://github.com/jeffzhangme/zapx。
它应该很容易适应这一点,以使用confluent-kafka-go和任何其他更改,根据您的需求,查看此项目的源代码。
https://stackoverflow.com/questions/63939617
复制相似问题