|
@@ -68,7 +68,6 @@ public class Kafka {
|
|
|
for (Object o : datas) {
|
|
|
sendResult.add(sendMessage(connection, topic, DataFormatUtil.toString(o)));
|
|
|
}
|
|
|
- return UniReturnUtil.success(sendResult);
|
|
|
} else {
|
|
|
Producer<String, String> producer = producerPool.borrowObject(connection);
|
|
|
sendResult.add(producer.send(new ProducerRecord<>(topic, DataFormatUtil.toString(data))));
|
|
@@ -77,7 +76,7 @@ public class Kafka {
|
|
|
return UniReturnUtil.success(sendResult);
|
|
|
}
|
|
|
|
|
|
- public static Map<String, Object> reception(String connectConfig, String sourceObjectName, String libraryId, String pollNumber, String fetch) throws Exception {
|
|
|
+ public static Map<String, Object> receptionMessage(String connectConfig, String sourceObjectName, String libraryId, String pollNumber, String fetch) throws Exception {
|
|
|
Map<String, Object> connectConfigMaps = (Map<String, Object>) DataFormatUtil.stringToMap(connectConfig);
|
|
|
if (!connectConfigMaps.containsKey("group.id")) {
|
|
|
connectConfigMaps.put("group.id", "groupid" + (String.format("%s", libraryId)));
|