Merge pull request #7 from pavankjadda/kafka_2.1.0-upgrade

Kafka 2.1.0 upgrade

Author: pavankjadda

README.md

@@ -5,8 +5,11 @@ This repository demonstrates [CQRS](https://www.confluent.io/blog/event-sourcing
 ## How to Run?
 1. Download and install Kafka either from [Confluent](https://docs.confluent.io/current/installation/installing_cp.html#zip-and-tar-archives) or follow instructions [from here](https://www.tutorialspoint.com/apache_kafka/apache_kafka_installation_steps.htm) first. I recommend [Confluent](https://docs.confluent.io/current/installation/installing_cp.html#zip-and-tar-archives) as it combines all the servers into one package with additional tools.
 2. Clone this repository and open in IntelliJ or Eclipse as maven project and run `KafkaStreamApplication` class. This will bring up producer class.
-3. Open http://localhost:8090/orders or http://localhost:8090/customers or http://localhost:8090/sendevents to send kafka evensts (objects). 
-4. Modify [code](https://github.com/pavankjadda/KafkaStream-CQRS-EventSourcing/blob/master/src/main/java/com/kafkastream/web/EventsController.java), if you want to send events with dofferent information.
+3. Go to http://localhost:9021 => Topics=> create topics `customer`, `order` and `order-to-ktable` (if they do not exist)
+4. Go to EventsListener class and execute main method to start REST Proxy (Jetty) then access Kafka data through REST API
+5. Open http://localhost:8090/orders or http://localhost:8090/customers or http://localhost:8090/sendevents to send kafka events (objects). 
+6. Go to http://localhost:8095/customer-orders/all to see all customer orders fetched from Kafka State Store. See [StateStore Rest](https://github.com/pavankjadda/KafkaStream-CQRS-EventSourcing/blob/master/src/main/java/com/kafkastream/web/kafkarest/StateStoreRestService.java) Api for possible methods, you can customize it further
+7. Modify [code](https://github.com/pavankjadda/KafkaStream-CQRS-EventSourcing/blob/master/src/main/java/com/kafkastream/web/EventsController.java), if you want to send events with different information.
 
 ## Technologies Used
 1. Kafka Streams [(Confluent)](https://docs.confluent.io/current/platform.html)

pom.xml

@@ -14,7 +14,7 @@
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>2.0.1.RELEASE</version>
+        <version>2.1.1.RELEASE</version>
         <relativePath/> <!-- lookup parent from repository -->
     </parent>
 
@@ -24,6 +24,8 @@
         <java.version>1.8</java.version>
         <spring-cloud.version>Finchley.BUILD-SNAPSHOT</spring-cloud.version>
         <avro.version>1.8.2</avro.version>
+        <kafka.version>2.1.0</kafka.version>
+        <confluent.version>5.1.0</confluent.version>
     </properties>
 
     <dependencies>
@@ -56,30 +58,17 @@
         <dependency>
             <groupId>io.confluent</groupId>
             <artifactId>kafka-streams-avro-serde</artifactId>
-            <version>4.1.0</version>
+            <version>${confluent.version}</version>
         </dependency>
-        <dependency>
-            <groupId>io.confluent</groupId>
-            <artifactId>kafka-avro-serializer</artifactId>
-            <version>3.2.1</version>
-        </dependency>
-
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>kafka_2.12</artifactId>
-            <version>1.1.0</version>
+            <version>${kafka.version}</version>
         </dependency>
-
         <dependency>
-            <groupId>io.confluent</groupId>
-            <artifactId>common-config</artifactId>
-            <version>4.1.0</version>
-        </dependency>
-
-        <dependency>
-        <groupId>org.apache.avro</groupId>
-        <artifactId>avro</artifactId>
-        <version>${avro.version}</version>
+            <groupId>org.apache.avro</groupId>
+            <artifactId>avro</artifactId>
+            <version>${avro.version}</version>
         </dependency>
 
 

src/main/java/com/kafkastream/constants/KafkaConstants.java

@@ -0,0 +1,23 @@
+package com.kafkastream.constants;
+
+public class KafkaConstants
+{
+    public static String schemaRegistryUrl = "http://localhost:8081";
+    public static String APPLICATION_ID_CONFIG = "cqrs-streams";
+    public static String APPLICATION_SERVER_CONFIG = "localhost:8095";
+    public static String BOOTSTRAP_SERVERS_CONFIG = "localhost:9092";
+    public static String COMMIT_INTERVAL_MS_CONFIG = "2000";
+    public static String AUTO_OFFSET_RESET_CONFIG = "earliest";
+
+
+    public static String REST_PROXY_HOST = "localhost";
+    public static int REST_PROXY_PORT = 8095;
+
+
+    public static String orderTopic = "order";
+    public static String customerTopic = "customer";
+    public static String customerOrderTopic = "customer-order";
+    public static String greetingsTopic = "greetings";
+    public static String orderToKtableTopic = "order-to-ktable";
+
+}