我想给你写信 rsyslog 对于Kafka，使用 rsyslog $programname 或者 $syslogtag 不过，作为主题，omkafaka插件不接受params，我如何才能做到这一点？我试过使用 (type="omkafka" topic="$programname" ...) ，它失败了。
rsyslog
rsyslog $programname
$syslogtag
(type="omkafka" topic="$programname" ...)
oxcyiej71#
我自己解决了这个问题，omkafka 8.xx有一个新的属性来接受动态主题，只需配置这个属性并添加一个模板来注入动态主题。
template(name="kafka_topic" type="string" string="%programname%") input(type="imtcp" port="10514") action(type="omkafka" topic="kafka_topic" dynatopic="on" dynatopic.cachesize="1000" template="msg_template" broker=["xxx", "xxx", "xxx", "xxx"])
1条答案
按热度按时间oxcyiej71#
我自己解决了这个问题，omkafka 8.xx有一个新的属性来接受动态主题，只需配置这个属性并添加一个模板来注入动态主题。