mirror of
https://github.com/rsyslog/rsyslog.git
synced 2025-12-17 01:00:40 +01:00
Andre Lorbach
a4614d78cf
Added --enable-omkafka back and added --enable-imkafka to configure options. Only if both are enabled, kafka tests can be used and run. testbench: replaced old kafka tests with new ones using imkafka/omkafka imkafka: Added support to custom parameters from confParam confParam works simular like in omkafka and can be used to set custom parameters. testbench: Added missing new kafka testfile
19 lines
486 B
Plaintext
19 lines
486 B
Plaintext
$IncludeConfig diag-common.conf
|
|
|
|
module(load="../plugins/imkafka/.libs/imkafka")
|
|
/* Polls messages from kafka server!*/
|
|
input( type="imkafka"
|
|
topic="static"
|
|
broker="localhost:29092"
|
|
consumergroup="default"
|
|
confParam=[ "compression.codec=snappy",
|
|
"socket.timeout.ms=1000",
|
|
"socket.keepalive.enable=true"]
|
|
)
|
|
|
|
template(name="outfmt" type="string" string="%msg:F,58:2%\n")
|
|
|
|
if ($msg contains "msgnum:") then {
|
|
action( type="omfile" file="rsyslog.out.log" template="outfmt" )
|
|
}
|