消息队列Kafka版可以作为Output接入Logstash。本文说明如何在公网环境下通过Logstash向消息队列Kafka版发送消息。
前提条件
- 购买并部署消息队列Kafka版实例。具体操作,请参见公网+VPC接入。
- 下载并安装Logstash。具体操作,请参见Download Logstash。
- 下载并安装JDK 8。具体操作,请参见Download JDK 8。
步骤一:获取接入点
Logstash通过消息队列Kafka版的接入点与消息队列Kafka版建立连接。
步骤二:创建Topic
创建用于存储消息的Topic。
步骤三:Logstash发送消息
在安装了Logstash的机器上启动Logstash,向创建的Topic发送消息。
步骤四:查看Topic分区
查看消息发送到Topic的情况。
步骤五:按位点查询消息
您可以根据发送的消息的分区ID和位点信息查询该消息。
- 登录消息队列Kafka版控制台。
- 在左侧导航栏,单击实例列表。
- 在实例列表页面,单击目标实例名称。
- 在左侧导航栏,单击消息查询。
- 在消息查询页面,单击按位点查询页签。
- 从请输入Topic列表,选择发送了消息的Topic,从请选择分区列表,选择发送的消息的分区ID,从请输入位点列表,选择发送的消息的位点,然后单击查询。
- 可选:在查询结果右侧,可以查看消息详情。
更多信息
更多参数设置,请参见Kafka output plugin。