Skip to content

Latest commit

 

History

History

APIJSONDemo-MultiDataSource-Kafka

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 
 
 

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