out_kafka2
is included in td-agent
. Fluentd gem users will need to install the fluent-plugin-kafka
gem using the following command:@type
(required)kafka2
.brokers
(required/optional)localhost:9092
topic_key
app
, this plugin writes events to the app
topic.topic
default_topic
nil
)topic_key
field is missing.<format>
Directivejson
, ltsv
, and formatter plugins.json
example:use_event_time
CreateTime
.false
(It means the current time.)required_acks
-1
compression_codec
nil
).nil
gzip
, snappy
snappy
, you need to install snappy
gem by td-agent-gem
command.@log_level
@log_level
option allows the user to set different levels of logging for each plugin.fatal
, error
, warn
, info
, debug
, trace
.