|
|
@@ -91,8 +91,8 @@ public class MessageConsumer {
|
|
|
ConsumerRecords<String, String> records = consumer.poll(maxPollIntervalMillis);
|
|
|
logger.info("topic: " + topics + " pool return records size: " + records.count());
|
|
|
for (ConsumerRecord<String, String> record : records) {
|
|
|
- logger.info("receiving batchCode... " + batchCode);
|
|
|
String value = record.value();
|
|
|
+ logger.info("receiving batchCode... " + value);
|
|
|
if(value.equals(batchCode)){
|
|
|
processed = true;
|
|
|
} else{
|