Home Explore Help
Register Sign In
root
/
EMS_server
Watch 2
Star 0
Fork 0
Files Issues 0 Pull Requests 0 Wiki
Browse Source

kafka读取数据修改

sl 3 months ago
parent
91b52f32b9
commit
8ae7b28825
1 changed files with 0 additions and 1 deletions
Unified View Show Diff Stats
  1. 0 1
      module_ems/src/main/java/org/jeecg/modules/kafka/consumer/TestConsumer.java

+ 0 - 1
module_ems/src/main/java/org/jeecg/modules/kafka/consumer/TestConsumer.java
View File 

@@ -124,7 +124,6 @@ public class TestConsumer {
 
             map1.put(key.toString(), jsonObject.get(key));
 
             map1.put(key.toString(), jsonObject.get(key));
 
         }
 
         }
 
         map.put("properties", map1);
 
         map.put("properties", map1);
 
-
 
         mongoTemplate.insert(map, collectionName);
 
         mongoTemplate.insert(map, collectionName);
 
     }
 
     }
 
 //    private void saveData(ConsumerRecord<?, ?> record, String collectionName) {
 
 //    private void saveData(ConsumerRecord<?, ?> record, String collectionName) {