Skip to content

Instantly share code, notes, and snippets.

@taotetek
Created May 31, 2016 20:01
Show Gist options
  • Save taotetek/e0678ca43a978602ba125f96ad40eac7 to your computer and use it in GitHub Desktop.
Save taotetek/e0678ca43a978602ba125f96ad40eac7 to your computer and use it in GitHub Desktop.
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"
)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment