模拟kafka发送数据,首先需要使用vscode,下载安装Kafka扩展Tools for Apache Kafka®
选择侧边栏kafka的图片,点击上面的加好,添加相应的name和Bootstrap server
然后新建文件夹,以kafka后缀结尾,例如test.kafka
,文件内容如下所示
PRODUCER ttt
topic: TOPIC_RISK_BAN_MSG
{
"userId":1234566,
"status":"CLOSED",
"endTime":"9999-12-31 23:59:59"
}
输入完成后选择produce record
,即可发送kafka消息