我是Kafka的新手,正在尝试建立一个管道,将我的apache httpd日志连接到mongodb。 我有用Kafka Output从Filebeat产生的数据。然后使用Kafka Connect to a database (MongoDB)将数据下沉。不幸的是,我的Filebeat中的数据没有ID。
现在,我尝试将Filebeat添加到其中,并将其配置为索引来自Kafka主题的数据。kibanaRef: config: - type: kafka在pod的日志中,我可以看到如下条目 log/log.go:145 Non-zero metrics in the last 30s {"monitoring": {"metrics": {
在server1上,我有一个运行Kafka的docker容器。Kafka代理端口和动物园管理员被映射到主机。在server2上,我想安装Filebeat,它向server1上的Kafka发送一些日志消息。它似乎可以建立起与经纪人的联系.:
[kafka] kafka/client.go:317 Kafka (topic=sample-topic): kafka: client has run out of avail