From 526c76e72e51de36ea9dde8c25546dbd0661174a Mon Sep 17 00:00:00 2001 From: Jay Ehsaniara Date: Tue, 15 Jun 2021 22:35:14 -0700 Subject: [PATCH] updating scs-099 vars --- .../com/ehsaniara/scs_kafka_intro/scs099/PobSubService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/scs-099/src/main/java/com/ehsaniara/scs_kafka_intro/scs099/PobSubService.java b/scs-099/src/main/java/com/ehsaniara/scs_kafka_intro/scs099/PobSubService.java index e6d05d2..765b8e2 100644 --- a/scs-099/src/main/java/com/ehsaniara/scs_kafka_intro/scs099/PobSubService.java +++ b/scs-099/src/main/java/com/ehsaniara/scs_kafka_intro/scs099/PobSubService.java @@ -38,7 +38,7 @@ public class PobSubService { IntStream.range(0, 10) .forEach(value -> { //this is our Message payload - String message = String.format("TestString of %s - %s", counter, value); + var message = String.format("TestString of %s - %s", counter, value); //here is out message publisher in the given channel into topic "scs-099.order" myBinder.orderOut().send(MessageBuilder.withPayload(message).build());