rsyslog 入门 第三篇 omkafka

rsyslog 这种神器，当然是各种姿势都支持。。。kafka 必需可以

template 跟 input ， 是一样的,可以参考上一篇。主要是ruleset。


module(load="omkafka")

ruleset(name="nginx") {
action (
queue.workerthreads="1"                    #队列的工作线程。
type="omkafka"
failedMsgFile="omkafka-failed.data"      ##8.28版本 或之后，需要这一句。之前的版本则需要去掉。
topic="web"                                       #需要修改，对应的kafka topic名称，定义好名称之后，kafka这边会创建
broker=["10.30.187.28:9092"]
template="template-name"
errorfile="/data/kafka-log/kafka_errorfile.log"
)
}