rsyslog寫$ programname作爲kafka話題

Question

我想從rsyslog寫信給kafka，使用rsyslog $programname或$syslogtag作爲主題，但是，omkafaka插件不接受params，我該如何實現這一目標？

我試過使用(type="omkafka" topic="$programname" ...)，它失敗了。

Answer 1

我自己解決了這個問題，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"])