updating scs-099 tutorial

scs-099/README.md

@@ -2,7 +2,9 @@
 
 ## Producer Consumer
 
-A simple Example of an Event Driven Flow by the help of **SPRING CLOUD STREAM KAFKA**
+A simple example for an Event Driven Flow by the help of **SPRING CLOUD STREAM KAFKA**
+
+![General Flow Diagram](material/kafka-events-intro-099-1.svg)
 
 ##### properties
 
@@ -12,8 +14,6 @@ A simple Example of an Event Driven Flow by the help of **SPRING CLOUD STREAM KA
 
 The Docker-compose file contains: single kafka and zookeeper. just simply run the following command
 
-![General Flow Diagram](material/kafka-events-intro-099-1.svg)
-
 ```shell
 docker-compose up -d
 ```

scs-099/src/main/java/com/ehsaniara/scs_kafka_intro/scs099/PobSubService.java

@@ -41,10 +41,7 @@ public class PobSubService {
                         String 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)
-                                        .setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.APPLICATION_JSON)
-                                        .build());
+                        myBinder.orderOut().send(MessageBuilder.withPayload(message).build());
 
                         //to show what we have produced in kafka ("WARN" to show in different color on the console)
                         log.warn("message produced: {}", message);

scs-099/src/main/resources/application.yml

@@ -17,7 +17,7 @@ spring:
   cloud.stream.bindings:
     order-out.producer.partition-count: 10
     order-in:
-      group: ${spring.application.name}-shipping-group
+      group: ${spring.application.name}-group
       consumer.concurrency: 1
 
   cloud.stream.kafka.binder:
@@ -31,7 +31,7 @@ spring:
   cloud.stream.bindings:
     order-out.producer.partition-count: 10
     order-in:
-      group: ${spring.application.name}-shipping-group
+      group: ${spring.application.name}-group
       consumer.concurrency: 3
 
   cloud.stream.kafka.binder: