File tree Expand file tree Collapse file tree 1 file changed +34
-1
lines changed 
APIJSON-Java-Server/APIJSONDemo-MultiDataSource-Kafka Expand file tree Collapse file tree 1 file changed +34
-1
lines changed Original file line number Diff line number Diff line change 99Access表名 = 消息队列 topic
1010
1111Access表配置说明:
12+ ![ image] ( https://user-images.githubusercontent.com/12228225/210956299-204115a7-433c-4f18-af27-5120068dab2e.png ) 
13+ Request表配置post权限
14+ ![ image] ( https://user-images.githubusercontent.com/12228225/210956378-be095589-0ced-4317-bb46-6b296538f26e.png ) 
1215
13- ![ image-20230106155124881] (/Users/xy/Library/Application Support/typora-user-images/image-20230106155124881.png)
16+ apijson发送mq消息:
17+ 单条
18+ {
19+ "@datasource  ": "kafka",
20+  "Topic_User":{
21+  "message":"test-101"
22+  },
23+  "tag": "Topic_User",
24+  "@explain  ": false
25+ }
26+ 多条
27+ {
28+  "Topic_User[ ] ": [ 
29+  {
30+  "message":"test-100"
31+  },
32+  {
33+  "message":"test-101"
34+  }
35+  ] ,
36+  "tag": "Topic_User[ ] ",
37+  "@datasource  ": "kafka",
38+  "@explain  ": true
39+ }
40+ 
41+ 客户端接收消息:
42+ offset = 47, key = null, value = test-101
43+ offset = 48, key = null, value = test-100
44+ offset = 49, key = null, value = test-101
45+ 
46+ 用java代码方式,获取具体数据源,调用即可
                         You can’t perform that action at this time. 
           
                  
0 commit comments