Я хочу писать сообщения от rsyslog до kafka, используйте rsyslog $programname или $syslogtag как тему, однако плагин omkafaka не принимает параметры, как я могу это достичь?
Я пробовал использовать (type="omkafka" topic="$programname" ...), он терпит неудачу.
Я решил это самостоятельно, 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"])
Я решил это самостоятельно, omkafka 8.xx имеет новое свойство принимать динамическую тему. Но все равно спасибо. – sayume
вы можете поместить решение, которое работало в поле ответа, и принять его самостоятельно – Nishant