gistfile1.txt

ruleset(name="kafka_publish_raw") {
  action(
    name="to_kafka"
    type="omkafka"
    broker=["prod-kafka01",
            "prod-kafka02",
            "prod-kafka03"]
    topic="rawlogs"
    confParam=["socket.keepalive.enable=true","socket.timeout.ms=1000"]
    partitions.auto="on"
    errorFile="/var/log/omkafka.err"
    template="RSYSLOG_ForwardFormat"
  )
}