Skip to content

Latest commit

 

History

History
48 lines (38 loc) · 1 KB

File metadata and controls

48 lines (38 loc) · 1 KB

APIJSONDemo

支持多数据源-消息队列

示例:kafka

原理说明:

Access表名 = 消息队列 topic

Access表配置说明: image Request表配置post权限 image

apijson发送mq消息: 单条
{ "@datasource": "kafka", "Topic_User":{ "message":"test-101" }, "tag": "Topic_User", "@explain": false }
多条
{ "Topic_User[]": [ { "message":"test-100" }, { "message":"test-101" } ], "tag": "Topic_User[]", "@datasource": "kafka", "@explain": true }

客户端接收消息:

offset = 47, key = null, value = test-101
offset = 48, key = null, value = test-100
offset = 49, key = null, value = test-101

用java代码方式,获取具体数据源,调用即可

close