mirror of
https://github.com/rsyslog/rsyslog.git
synced 2025-12-16 20:20:41 +01:00
Andre Lorbach
a65096dee2
Test uses all three kafka instances and all kafka instances uses three zookeeper instances. Testbench proberly needs to be adapted...
35 lines
1.1 KiB
Plaintext
35 lines
1.1 KiB
Plaintext
$IncludeConfig diag-common2.conf
|
|
|
|
module(load="../plugins/omkafka/.libs/omkafka")
|
|
module(load="../plugins/imtcp/.libs/imtcp")
|
|
input(type="imtcp" port="13514" Ruleset="omkafka") /* this port for tcpflood! */
|
|
|
|
template(name="outfmt" type="string" string="%msg%\n")
|
|
|
|
ruleset(name="omkafka") {
|
|
action( type="omkafka"
|
|
name="kafka-fwd"
|
|
broker=["localhost:29092", "localhost:29093", "localhost:29094"]
|
|
topic="static"
|
|
template="outfmt"
|
|
partitions.auto="on"
|
|
partitions.scheme="random"
|
|
queue.size="1000000"
|
|
queue.type="LinkedList"
|
|
action.repeatedmsgcontainsoriginalmsg="off"
|
|
action.resumeRetryCount="-1"
|
|
action.reportSuspension="on"
|
|
action.reportSuspensionContinuation="on" )
|
|
|
|
}
|
|
|
|
ruleset(name="omkafka1") {
|
|
action(name="kafka-fwd" type="omkafka" topic="static" broker="localhost:29092" template="outfmt" partitions.auto="on")
|
|
}
|
|
ruleset(name="omkafka2") {
|
|
action(name="kafka-fwd" type="omkafka" topic="static" broker="localhost:29093" template="outfmt" partitions.auto="on")
|
|
}
|
|
ruleset(name="omkafka3") {
|
|
action(name="kafka-fwd" type="omkafka" topic="static" broker="localhost:29094" template="outfmt" partitions.auto="on")
|
|
}
|