示例:kafka
原理说明:
Access表名 = 消息队列 topic
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代码方式,获取具体数据源,调用即可