模拟kafka发送数据

发布于 2021-08-25 17:52:16 阅读 991

模拟kafka发送数据,首先需要使用vscode,下载安装Kafka扩展Tools for Apache Kafka®

WX20210825-175437.png

选择侧边栏kafka的图片,点击上面的加好,添加相应的name和Bootstrap server

WX20210825-175541.png

然后新建文件夹,以kafka后缀结尾,例如test.kafka,文件内容如下所示

PRODUCER ttt
topic: TOPIC_RISK_BAN_MSG
{
    "userId":1234566,
    "status":"CLOSED",
    "endTime":"9999-12-31 23:59:59"
}

WX20210825-175810.png

输入完成后选择produce record,即可发送kafka消息