制作带有kafka插件和es插件的fluentd镜像是怎样的

2023-04-07 15:27:00 镜像 插件 是怎样

在fluentd中安装kafka插件和es插件需要做哪些配置?

为了使fluentd支持kafka和es,需要安装kafka插件和es插件。安装kafka插件的命令是:

gem install fluent-plugin-kafka

安装es插件的命令是:

gem install fluent-plugin-elasticsearch

配置kafka插件

在fluentd的配置文件中添加如下内容:

@type kafka brokers 127.0.0.1:9092 topic_key topic default_topic test

配置es插件

在fluentd的配置文件中添加如下内容:

@type elasticsearch host 127.0.0.1 port 9200 logstash_format true logstash_prefix test

相关文章