Browse Source

Merge remote-tracking branch 'origin/dev' into dev

dongbw 8 years ago
parent
commit
9e9aa1964f
1 changed files with 1 additions and 1 deletions
  1. 1 1
      src/main/java/com/uas/ps/product/MessageConsumer.java

+ 1 - 1
src/main/java/com/uas/ps/product/MessageConsumer.java

@@ -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{