消息队列Kafka版可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向消息队列Kafka版发送消息。
前提条件
- 购买并部署消息队列Kafka版实例。详情请参见VPC接入。
- 下载并安装Filebeat。详情请参见Download Filebeat。
- 下载并安装JDK 8。详情请参见Download JDK 8。
步骤一:获取接入点
Filebeat通过消息队列Kafka版的接入点与消息队列Kafka版建立连接。
步骤二:创建Topic
创建用于存储消息的Topic。
步骤三:Filebeat发送消息
在安装了Filebeat的机器上启动Filebeat,向创建的Topic发送消息。
- 执行cd命令切换到Filebeat的安装目录。
- 创建output.conf配置文件。
- 向创建的Topic发送消息。
- 执行
./filebeat -c ./output.yml
。 - 输入test,然后按回车键。
- 执行
步骤四:查看Topic分区
查看消息发送到Topic的情况。
步骤五:按位点查询消息
您可以根据发送的消息的分区ID和位点信息查询该消息。