|
@@ -80,6 +80,7 @@ public class KafkaDataProcess {
|
|
for (IntStatusDto status : intStatusLists) {
|
|
for (IntStatusDto status : intStatusLists) {
|
|
if (status.getNodeId() > 1000000000) {
|
|
if (status.getNodeId() > 1000000000) {
|
|
buffer.put(status.getKafkaData());
|
|
buffer.put(status.getKafkaData());
|
|
|
|
+ this.kafkaProducer.sendNode(Long.toString(status.getNodeId()), status.getKafkaData());
|
|
}
|
|
}
|
|
}
|
|
}
|
|
this.kafkaProducer.sendSig(center.getRegionCd(), buffer.array());
|
|
this.kafkaProducer.sendSig(center.getRegionCd(), buffer.array());
|