File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -551,9 +551,9 @@ public class PublisherServiceImpl implements PublisherService {
551551
552552 future.whenComplete((result , ex ) -> {
553553 if (ex == null ) {
554- System .out .println (" ✅ Message successfully sent to topic: " + getUpdateLightMeasurementTopic () + " with key: " + key );
554+ System .out .println (" Message successfully sent to topic: " + getUpdateLightMeasurementTopic () + " with key: " + key );
555555 } else {
556- System .err .println (" ❌ Failed to send message to topic: " + getUpdateLightMeasurementTopic () + " with key: " + key );
556+ System .err .println (" Failed to send message to topic: " + getUpdateLightMeasurementTopic () + " with key: " + key );
557557 ex .printStackTrace ();
558558 }
559559 });
@@ -567,9 +567,9 @@ public class PublisherServiceImpl implements PublisherService {
567567
568568 try {
569569 kafkaTemplate.send(message ).get(10, TimeUnit .SECONDS );
570- System.out.println("✅ Message successfully sent synchronously to topic : " + getUpdateLightMeasurementTopic() + " with key : " + key);
570+ System.out.println("Message successfully sent synchronously to topic : " + getUpdateLightMeasurementTopic() + " with key : " + key);
571571 } catch (InterruptedException | ExecutionException | TimeoutException e ) {
572- System .err .println (" ❌ Failed to send message synchronously to topic: " + getUpdateLightMeasurementTopic () + " with key: " + key );
572+ System .err .println (" Failed to send message synchronously to topic: " + getUpdateLightMeasurementTopic () + " with key: " + key );
573573 e .printStackTrace ();
574574 }
575575 }
You can’t perform that action at this time.
0 commit comments