From 4392b1b8c74f303f12b0500061427156f87e2515 Mon Sep 17 00:00:00 2001
From: Nasruddin <nasruddin.java@gmail.com>
Date: Thu, 14 Apr 2022 11:07:40 +0530
Subject: [PATCH] Cleaning up

---
 .idea/compiler.xml                            |  4 +-
 .idea/encodings.xml                           |  4 ++
 .idea/jarRepositories.xml                     | 10 ++++
 .idea/misc.xml                                |  4 ++
 .idea/runConfigurations.xml                   | 10 ----
 api-gateway-service/Dockerfile                | 31 ++++++++++
 api-gateway-service/pom.xml                   |  2 +-
 .../src/main/resources/application.yml        |  3 +-
 .../{application.yml => bootstrap.yml}        |  6 +-
 docker/docker-compose-elasticsearch.yml       | 30 ++++++++++
 docker/docker-compose-kafka.yml               | 21 ++-----
 docker/docker-compose-postgres.yml            |  8 ++-
 docker/docker-compose-redis.yml               |  4 +-
 docker/docker-compose.yml                     | 20 +++----
 pom.xml                                       |  2 +
 search-engine/Dockerfile                      | 31 ++++++++++
 .../searchengine/StudentRepository.java       | 11 ++++
 .../javatab/searchengine/api/SearchApi.java   | 37 ++++++++++++
 .../configuration/ElasticConfig.java          | 18 ++++++
 .../configuration/MessageFunctionConfig.java  | 16 +++++
 .../javatab/searchengine/domain/Course.java   | 13 ++++
 .../javatab/searchengine/domain/Student.java  | 15 +++++
 .../searchengine/service/StudentService.java  | 59 +++++++++++++++++++
 student-service/Dockerfile                    | 31 ++++++++++
 student-service/pom.xml                       |  5 +-
 .../main/java/com/javatab/student/Event.java  | 52 ++++++++++++++++
 .../student/MessageFunctionConfiguration.java | 14 ++++-
 .../javatab/student/StudentController.java    |  1 +
 .../src/main/resources/application.yml        |  8 ++-
 29 files changed, 414 insertions(+), 56 deletions(-)
 delete mode 100644 .idea/runConfigurations.xml
 create mode 100644 api-gateway-service/Dockerfile
 rename config-server/src/main/resources/{application.yml => bootstrap.yml} (73%)
 create mode 100644 docker/docker-compose-elasticsearch.yml
 create mode 100644 search-engine/Dockerfile
 create mode 100644 search-engine/src/main/java/com/javatab/searchengine/StudentRepository.java
 create mode 100644 search-engine/src/main/java/com/javatab/searchengine/api/SearchApi.java
 create mode 100644 search-engine/src/main/java/com/javatab/searchengine/configuration/ElasticConfig.java
 create mode 100644 search-engine/src/main/java/com/javatab/searchengine/configuration/MessageFunctionConfig.java
 create mode 100644 search-engine/src/main/java/com/javatab/searchengine/domain/Course.java
 create mode 100644 search-engine/src/main/java/com/javatab/searchengine/domain/Student.java
 create mode 100644 search-engine/src/main/java/com/javatab/searchengine/service/StudentService.java
 create mode 100644 student-service/Dockerfile
 create mode 100644 student-service/src/main/java/com/javatab/student/Event.java

diff --git a/.idea/compiler.xml b/.idea/compiler.xml
index 72a3666..e764ad6 100644
--- a/.idea/compiler.xml
+++ b/.idea/compiler.xml
@@ -9,9 +9,10 @@
         <outputRelativeToContentRoot value="true" />
         <module name="course-service" />
         <module name="config-server" />
-        <module name="student-service" />
         <module name="auth-service" />
         <module name="api-gateway-service" />
+        <module name="search-engine" />
+        <module name="student-service" />
         <module name="discovery-service" />
       </profile>
     </annotationProcessing>
@@ -27,6 +28,7 @@
       <module name="config-server" options="-parameters" />
       <module name="course-service" options="-parameters" />
       <module name="discovery-service" options="-parameters" />
+      <module name="search-engine" options="-parameters" />
       <module name="student-service" options="-parameters" />
     </option>
   </component>
diff --git a/.idea/encodings.xml b/.idea/encodings.xml
index 47964ca..fd9654e 100644
--- a/.idea/encodings.xml
+++ b/.idea/encodings.xml
@@ -7,6 +7,10 @@
     <file url="file://$PROJECT_DIR$/config-server/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/course-service/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/discovery-service/src/main/java" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/search-engine/src/main/java" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/search-engine/src/main/resources" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
+    <file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/student-service/src/main/java" charset="UTF-8" />
     <file url="file://$PROJECT_DIR$/student-service/src/main/resources" charset="UTF-8" />
   </component>
diff --git a/.idea/jarRepositories.xml b/.idea/jarRepositories.xml
index ec05f0e..e20a4a2 100644
--- a/.idea/jarRepositories.xml
+++ b/.idea/jarRepositories.xml
@@ -6,6 +6,11 @@
       <option name="name" value="Central Repository" />
       <option name="url" value="https://repo.maven.apache.org/maven2" />
     </remote-repository>
+    <remote-repository>
+      <option name="id" value="Maven repository" />
+      <option name="name" value="Maven repository" />
+      <option name="url" value="http://central.maven.org/maven2/" />
+    </remote-repository>
     <remote-repository>
       <option name="id" value="central" />
       <option name="name" value="Maven Central repository" />
@@ -16,6 +21,11 @@
       <option name="name" value="JBoss Community repository" />
       <option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
     </remote-repository>
+    <remote-repository>
+      <option name="id" value="Nexus repository" />
+      <option name="name" value="Nexus repository" />
+      <option name="url" value="https://nexus.client.com/repository/maven-public/" />
+    </remote-repository>
     <remote-repository>
       <option name="id" value="central" />
       <option name="name" value="Central Repository" />
diff --git a/.idea/misc.xml b/.idea/misc.xml
index e555a0a..29bad36 100644
--- a/.idea/misc.xml
+++ b/.idea/misc.xml
@@ -9,8 +9,12 @@
         <option value="$PROJECT_DIR$/common-service/pom.xml" />
         <option value="$PROJECT_DIR$/api-gateway-service/pom.xml" />
         <option value="$PROJECT_DIR$/student-service/pom.xml" />
+        <option value="$PROJECT_DIR$/search-engine/pom.xml" />
       </list>
     </option>
   </component>
   <component name="ProjectRootManager" version="2" languageLevel="JDK_11" default="true" project-jdk-name="11" project-jdk-type="JavaSDK" />
+  <component name="ProjectType">
+    <option name="id" value="jpab" />
+  </component>
 </project>
\ No newline at end of file
diff --git a/.idea/runConfigurations.xml b/.idea/runConfigurations.xml
deleted file mode 100644
index 797acea..0000000
--- a/.idea/runConfigurations.xml
+++ /dev/null
@@ -1,10 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project version="4">
-  <component name="RunConfigurationProducerService">
-    <option name="ignoredProducers">
-      <set>
-        <option value="com.android.tools.idea.compose.preview.runconfiguration.ComposePreviewRunConfigurationProducer" />
-      </set>
-    </option>
-  </component>
-</project>
\ No newline at end of file
diff --git a/api-gateway-service/Dockerfile b/api-gateway-service/Dockerfile
new file mode 100644
index 0000000..b237fbd
--- /dev/null
+++ b/api-gateway-service/Dockerfile
@@ -0,0 +1,31 @@
+#stage 1
+#Start with a base image containing Java runtime
+FROM openjdk:11-slim as build
+
+# Add Maintainer Info
+LABEL maintainer="Nasruddin <nasruddin.java@gmail.com>"
+
+# The application's jar file
+ARG JAR_FILE
+
+# Add the application's jar to the container
+COPY ${JAR_FILE} app.jar
+
+#unpackage jar file
+RUN mkdir -p target/dependency && (cd target/dependency; jar -xf /app.jar)
+
+#stage 2
+#Same Java runtime
+FROM openjdk:11-slim
+
+#Add volume pointing to /tmp
+VOLUME /tmp
+
+#Copy unpackaged application to new container
+ARG DEPENDENCY=/target/dependency
+COPY --from=build ${DEPENDENCY}/BOOT-INF/lib /app/lib
+COPY --from=build ${DEPENDENCY}/META-INF /app/META-INF
+COPY --from=build ${DEPENDENCY}/BOOT-INF/classes /app
+
+#execute the application
+ENTRYPOINT ["java","-cp","app:app/lib/*","com.javatab.gatewayservice.ApiGatewayServiceApplication"]
\ No newline at end of file
diff --git a/api-gateway-service/pom.xml b/api-gateway-service/pom.xml
index 31111b1..4c33971 100644
--- a/api-gateway-service/pom.xml
+++ b/api-gateway-service/pom.xml
@@ -10,7 +10,7 @@
 	</parent>
 	<groupId>com.javatab</groupId>
 	<artifactId>api-gateway-service</artifactId>
-	<version>0.0.1-SNAPSHOT</version>
+	<version>1.0.0</version>
 	<name>api-gateway-service</name>
 	<description>Gateway Service using spring cloud gateway</description>
 	<properties>
diff --git a/auth-service/src/main/resources/application.yml b/auth-service/src/main/resources/application.yml
index cb8be23..cfa110b 100644
--- a/auth-service/src/main/resources/application.yml
+++ b/auth-service/src/main/resources/application.yml
@@ -26,9 +26,10 @@ spring:
           #  max-attempts: 3
 
   datasource:
-    url: jdbc:postgresql://localhost:5432/testdb
+    url: jdbc:postgresql://postgres_container1:5432/testdb
     username: postgres
     password: 123
+    driver-class-name: org.postgresql.Driver
   jpa:
     properties:
       hibernate:
diff --git a/config-server/src/main/resources/application.yml b/config-server/src/main/resources/bootstrap.yml
similarity index 73%
rename from config-server/src/main/resources/application.yml
rename to config-server/src/main/resources/bootstrap.yml
index 6bf835e..e915503 100644
--- a/config-server/src/main/resources/application.yml
+++ b/config-server/src/main/resources/bootstrap.yml
@@ -24,6 +24,10 @@ management:
         include: "*"
 
 eureka:
+  instance:
+    prefer-ip-address: true
   client:
     service-url:
-      default-zone: http://discoveryservice:8761/eureka/
\ No newline at end of file
+      defaultZone: ${EUREKA_SERVER:http://localhost:8761/eureka}
+    fetch-registry: true
+    register-with-eureka: true
\ No newline at end of file
diff --git a/docker/docker-compose-elasticsearch.yml b/docker/docker-compose-elasticsearch.yml
new file mode 100644
index 0000000..4c16693
--- /dev/null
+++ b/docker/docker-compose-elasticsearch.yml
@@ -0,0 +1,30 @@
+version: "3.8"
+services:
+  elasticsearch:
+    image: docker.elastic.co/elasticsearch/elasticsearch:7.7.0
+    container_name: elasticsearch
+    environment:
+      - node.name=elasticsearch
+      - discovery.type=single-node
+      - cluster.name=docker-cluster
+      - bootstrap.memory_lock=true
+      - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
+    ulimits:
+      memlock:
+        soft: -1
+        hard: -1
+  #  volumes:
+   #   - esdata1:/usr/share/elasticsearch/data
+    ports:
+      - "9300:9300"
+      - "9200:9200"
+    networks:
+      - backend
+
+networks:
+  backend:
+    driver: bridge
+
+#volumes:
+ # esdata1:
+  #  driver: local
\ No newline at end of file
diff --git a/docker/docker-compose-kafka.yml b/docker/docker-compose-kafka.yml
index 8d1b49b..817ea6e 100644
--- a/docker/docker-compose-kafka.yml
+++ b/docker/docker-compose-kafka.yml
@@ -5,35 +5,22 @@ services:
     ports:
       - "2181:2181"
     networks:
-      backend:
-        aliases:
-          - "zookeeper"
+      - backend
   kafkaserver:
     image: wurstmeister/kafka:latest
     ports:
       - "9092:9092"
     environment:
-      - KAFKA_ADVERTISED_HOST_NAME=192.168.1.8
+      - KAFKA_ADVERTISED_HOST_NAME=kafka
       - KAFKA_ADVERTISED_PORT=9092
       - KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
-      - KAFKA_CREATE_TOPICS=users:1:1,students:1:1,userCreatedOutput:1:1
     volumes:
       - "/var/run/docker.sock:/var/run/docker.sock"
     depends_on:
       - zookeeper
     networks:
-      backend:
-        aliases:
-          - "kafka"
+      - backend
 
 networks:
   backend:
-    driver: bridge
-   # redisserver:
-    #  image: redis:alpine
-     # ports:
-      #  - 6379:6379
-    #  networks:
-     #   backend:
-      #    aliases:
-       #     - "redis"
\ No newline at end of file
+    driver: bridge
\ No newline at end of file
diff --git a/docker/docker-compose-postgres.yml b/docker/docker-compose-postgres.yml
index f26a8f8..7ba4472 100644
--- a/docker/docker-compose-postgres.yml
+++ b/docker/docker-compose-postgres.yml
@@ -9,5 +9,11 @@ services:
       - "5432:5432"
     volumes:
       - database-data:/var/lib/postgresql/data/ # persist data even if container shuts down
+    networks:
+      - backend
 volumes:
-  database-data: # named volumes can be managed easier using docker-compose
\ No newline at end of file
+  database-data: # named volumes can be managed easier using docker-compose
+
+networks:
+  backend:
+    driver: bridge
\ No newline at end of file
diff --git a/docker/docker-compose-redis.yml b/docker/docker-compose-redis.yml
index c637274..bf83edb 100644
--- a/docker/docker-compose-redis.yml
+++ b/docker/docker-compose-redis.yml
@@ -5,9 +5,7 @@ services:
     ports:
       - "6379:6379"
     networks:
-      backend:
-        aliases:
-          - "redis"
+      - backend
 
 networks:
   backend:
diff --git a/docker/docker-compose.yml b/docker/docker-compose.yml
index 88b73ff..f029487 100644
--- a/docker/docker-compose.yml
+++ b/docker/docker-compose.yml
@@ -6,9 +6,7 @@ services:
     ports:
       - "8761:8761"
     networks:
-      backend:
-        aliases:
-          - "discoveryservice"
+      - backend
     #healthcheck:
      # test: [ "CMD", "curl", "-f", "http://discoveryservice:8761/eureka/" ]
      # interval: 30s
@@ -22,9 +20,10 @@ services:
     ports:
       - "8071:8071"
     networks:
-      backend:
-        aliases:
-          - "configserver"
+      - backend
+    environment:
+      - JAVA_OPTS=
+        -DEUREKA_SERVER=http://discoveryservice:8761/eureka
   auth-service:
     depends_on:
       - discoveryservice
@@ -34,9 +33,7 @@ services:
     ports:
       - "9100:9100"
     networks:
-      backend:
-        aliases:
-          - "authservice"
+      - backend
   apigatewayservice:
     depends_on:
       - discoveryservice
@@ -54,10 +51,7 @@ services:
     ports:
       - "8200:8200"
     networks:
-      backend:
-        aliases:
-          - "course-service"
-
+      - backend
 networks:
   backend:
     driver: bridge
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index 3360226..709a842 100644
--- a/pom.xml
+++ b/pom.xml
@@ -24,5 +24,7 @@
         <module>course-service</module>
         <module>api-gateway-service</module>
         <module>auth-service</module>
+        <module>student-service</module>
+        <module>search-engine</module>
     </modules>
 </project>
\ No newline at end of file
diff --git a/search-engine/Dockerfile b/search-engine/Dockerfile
new file mode 100644
index 0000000..2669ada
--- /dev/null
+++ b/search-engine/Dockerfile
@@ -0,0 +1,31 @@
+#stage 1
+#Start with a base image containing Java runtime
+FROM openjdk:11-slim as build
+
+# Add Maintainer Info
+LABEL maintainer="Nasruddin <nasruddin.java@gmail.com>"
+
+# The application's jar file
+ARG JAR_FILE
+
+# Add the application's jar to the container
+COPY ${JAR_FILE} app.jar
+
+#unpackage jar file
+RUN mkdir -p target/dependency && (cd target/dependency; jar -xf /app.jar)
+
+#stage 2
+#Same Java runtime
+FROM openjdk:11-slim
+
+#Add volume pointing to /tmp
+VOLUME /tmp
+
+#Copy unpackaged application to new container
+ARG DEPENDENCY=/target/dependency
+COPY --from=build ${DEPENDENCY}/BOOT-INF/lib /app/lib
+COPY --from=build ${DEPENDENCY}/META-INF /app/META-INF
+COPY --from=build ${DEPENDENCY}/BOOT-INF/classes /app
+
+#execute the application
+ENTRYPOINT ["java","-cp","app:app/lib/*","com.javatab.searchengine.SearchEngineApplication"]
\ No newline at end of file
diff --git a/search-engine/src/main/java/com/javatab/searchengine/StudentRepository.java b/search-engine/src/main/java/com/javatab/searchengine/StudentRepository.java
new file mode 100644
index 0000000..68ee649
--- /dev/null
+++ b/search-engine/src/main/java/com/javatab/searchengine/StudentRepository.java
@@ -0,0 +1,11 @@
+package com.javatab.searchengine;
+
+import com.javatab.searchengine.domain.Student;
+import org.springframework.data.repository.reactive.ReactiveCrudRepository;
+import org.springframework.stereotype.Repository;
+import reactor.core.publisher.Flux;
+
+@Repository
+public interface StudentRepository extends ReactiveCrudRepository<Student, String> {
+    Flux<Student> findStudentByUsername(String username);
+}
diff --git a/search-engine/src/main/java/com/javatab/searchengine/api/SearchApi.java b/search-engine/src/main/java/com/javatab/searchengine/api/SearchApi.java
new file mode 100644
index 0000000..48cee72
--- /dev/null
+++ b/search-engine/src/main/java/com/javatab/searchengine/api/SearchApi.java
@@ -0,0 +1,37 @@
+package com.javatab.searchengine.api;
+
+import com.javatab.searchengine.StudentRepository;
+import com.javatab.searchengine.domain.Student;
+import com.javatab.searchengine.service.StudentService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.io.IOException;
+import java.util.function.Supplier;
+
+@RestController
+@RequestMapping("/search")
+@RequiredArgsConstructor
+public class SearchApi {
+
+    private final StudentService studentService;
+    private final StudentRepository studentRepository;
+
+    @PostMapping("/create-index")
+    public Mono<Student> createStudentIndex(@RequestBody Student student) throws IOException {
+        return studentRepository.save(student);
+    }
+
+    @GetMapping("/id/{userid}")
+    public Mono<Student> getUserById(@PathVariable("userid") String id) throws IOException {
+        return studentRepository.findById(id);
+    }
+
+    @GetMapping("/username/{username}")
+    public Flux<Student> getUserByUsername(@PathVariable("username") String username) throws IOException {
+        return studentRepository.findStudentByUsername(username);
+    }
+}
diff --git a/search-engine/src/main/java/com/javatab/searchengine/configuration/ElasticConfig.java b/search-engine/src/main/java/com/javatab/searchengine/configuration/ElasticConfig.java
new file mode 100644
index 0000000..4ee8d1c
--- /dev/null
+++ b/search-engine/src/main/java/com/javatab/searchengine/configuration/ElasticConfig.java
@@ -0,0 +1,18 @@
+package com.javatab.searchengine.configuration;
+
+import org.apache.http.HttpHost;
+import org.elasticsearch.client.RestClient;
+import org.elasticsearch.client.RestHighLevelClient;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class ElasticConfig {
+
+    @Bean
+    public RestHighLevelClient client() {
+        return new RestHighLevelClient(
+                RestClient.builder(
+                        new HttpHost("localhost", 9200, "http")));
+    }
+}
diff --git a/search-engine/src/main/java/com/javatab/searchengine/configuration/MessageFunctionConfig.java b/search-engine/src/main/java/com/javatab/searchengine/configuration/MessageFunctionConfig.java
new file mode 100644
index 0000000..659b3cf
--- /dev/null
+++ b/search-engine/src/main/java/com/javatab/searchengine/configuration/MessageFunctionConfig.java
@@ -0,0 +1,16 @@
+package com.javatab.searchengine.configuration;
+
+import com.javatab.searchengine.domain.Student;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.function.Consumer;
+
+@Configuration
+public class MessageFunctionConfig {
+
+    @Bean
+    Consumer<Student> getNewlyCreatedStudent() { // change to event class instead of student
+        return student -> System.out.println("New created student " + student);
+    }
+}
\ No newline at end of file
diff --git a/search-engine/src/main/java/com/javatab/searchengine/domain/Course.java b/search-engine/src/main/java/com/javatab/searchengine/domain/Course.java
new file mode 100644
index 0000000..362e2e7
--- /dev/null
+++ b/search-engine/src/main/java/com/javatab/searchengine/domain/Course.java
@@ -0,0 +1,13 @@
+package com.javatab.searchengine.domain;
+
+import lombok.Builder;
+import lombok.Data;
+
+@Data
+@Builder
+public class Course {
+
+    private String courseId;
+    private String courseName;
+    private String description;
+}
diff --git a/search-engine/src/main/java/com/javatab/searchengine/domain/Student.java b/search-engine/src/main/java/com/javatab/searchengine/domain/Student.java
new file mode 100644
index 0000000..7bc967d
--- /dev/null
+++ b/search-engine/src/main/java/com/javatab/searchengine/domain/Student.java
@@ -0,0 +1,15 @@
+package com.javatab.searchengine.domain;
+
+import lombok.Builder;
+import lombok.Data;
+import org.springframework.data.elasticsearch.annotations.Document;
+
+@Data
+@Builder
+@Document(indexName = "student")
+public class Student {
+
+    private String id;
+    private String username;
+    private String email;
+}
diff --git a/search-engine/src/main/java/com/javatab/searchengine/service/StudentService.java b/search-engine/src/main/java/com/javatab/searchengine/service/StudentService.java
new file mode 100644
index 0000000..6dad630
--- /dev/null
+++ b/search-engine/src/main/java/com/javatab/searchengine/service/StudentService.java
@@ -0,0 +1,59 @@
+package com.javatab.searchengine.service;
+
+import com.javatab.searchengine.domain.Student;
+import lombok.RequiredArgsConstructor;
+import org.elasticsearch.action.get.GetRequest;
+import org.elasticsearch.action.get.GetResponse;
+import org.elasticsearch.action.index.IndexRequest;
+import org.elasticsearch.action.index.IndexResponse;
+import org.elasticsearch.client.RequestOptions;
+import org.elasticsearch.client.RestHighLevelClient;
+import org.elasticsearch.common.collect.Map;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.elasticsearch.common.xcontent.XContentType;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+import java.util.UUID;
+
+@Service
+@RequiredArgsConstructor
+public class StudentService {
+
+    private final RestHighLevelClient client;
+    private final ObjectMapper mapper;
+
+    public String createStudentDocument(Student student) throws IOException {
+        Student aStudent = Student.builder()
+                .id(UUID.randomUUID().toString())
+                .username(student.getUsername())
+                .email(student.getEmail()).build();
+
+        Map documentMapper = mapper.convertValue(student, Map.class);
+
+        IndexRequest indexRequest = new IndexRequest("student-document").id(student.getId())
+                .source(documentMapper, XContentType.JSON);
+
+        IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);
+
+        return indexResponse
+                .getResult()
+                .name();
+    }
+
+    public Student findById(String id) throws IOException {
+        GetRequest getRequest = new GetRequest("student-document", id);
+
+        GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
+        return mapper
+                .convertValue(getResponse.getSource(), Student.class);
+    }
+
+    public Student findByUsername(String username) throws IOException {
+        GetRequest getRequest = new GetRequest("student-document", username);
+
+        GetResponse getResponse = client.get(getRequest, RequestOptions.DEFAULT);
+        return mapper
+                .convertValue(getResponse.getSource(), Student.class);
+    }
+}
diff --git a/student-service/Dockerfile b/student-service/Dockerfile
new file mode 100644
index 0000000..9185d37
--- /dev/null
+++ b/student-service/Dockerfile
@@ -0,0 +1,31 @@
+#stage 1
+#Start with a base image containing Java runtime
+FROM openjdk:11-slim as build
+
+# Add Maintainer Info
+LABEL maintainer="Nasruddin <nasruddin.java@gmail.com>"
+
+# The application's jar file
+ARG JAR_FILE
+
+# Add the application's jar to the container
+COPY ${JAR_FILE} app.jar
+
+#unpackage jar file
+RUN mkdir -p target/dependency && (cd target/dependency; jar -xf /app.jar)
+
+#stage 2
+#Same Java runtime
+FROM openjdk:11-slim
+
+#Add volume pointing to /tmp
+VOLUME /tmp
+
+#Copy unpackaged application to new container
+ARG DEPENDENCY=/target/dependency
+COPY --from=build ${DEPENDENCY}/BOOT-INF/lib /app/lib
+COPY --from=build ${DEPENDENCY}/META-INF /app/META-INF
+COPY --from=build ${DEPENDENCY}/BOOT-INF/classes /app
+
+#execute the application
+ENTRYPOINT ["java","-cp","app:app/lib/*","com.javatab.student.StudentServiceApplication"]
\ No newline at end of file
diff --git a/student-service/pom.xml b/student-service/pom.xml
index 787701d..d2abad4 100644
--- a/student-service/pom.xml
+++ b/student-service/pom.xml
@@ -64,10 +64,7 @@
 				</exclusion>
 			</exclusions>
 		</dependency>
-		<!--<dependency>
-			<groupId>org.springframework.cloud</groupId>
-			<artifactId>spring-cloud-stream</artifactId>
-		</dependency>-->
+
 
 		<dependency>
 			<groupId>org.springframework.cloud</groupId>
diff --git a/student-service/src/main/java/com/javatab/student/Event.java b/student-service/src/main/java/com/javatab/student/Event.java
new file mode 100644
index 0000000..1a269ce
--- /dev/null
+++ b/student-service/src/main/java/com/javatab/student/Event.java
@@ -0,0 +1,52 @@
+package com.javatab.student;
+
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.datatype.jsr310.ser.ZonedDateTimeSerializer;
+
+import java.time.ZonedDateTime;
+
+import static java.time.ZonedDateTime.now;
+
+public class Event<K, T> {
+
+    public enum Type {
+        CREATE,
+        DELETE
+    }
+
+    private final Type eventType;
+    private final K key;
+    private final T data;
+    private final ZonedDateTime eventCreatedAt;
+
+    public Event() {
+        this.eventType = null;
+        this.key = null;
+        this.data = null;
+        this.eventCreatedAt = null;
+    }
+
+    public Event(Type eventType, K key, T data) {
+        this.eventType = eventType;
+        this.key = key;
+        this.data = data;
+        this.eventCreatedAt = now();
+    }
+
+    public Type getEventType() {
+        return eventType;
+    }
+
+    public K getKey() {
+        return key;
+    }
+
+    public T getData() {
+        return data;
+    }
+
+    @JsonSerialize(using = ZonedDateTimeSerializer.class)
+    public ZonedDateTime getEventCreatedAt() {
+        return eventCreatedAt;
+    }
+}
diff --git a/student-service/src/main/java/com/javatab/student/MessageFunctionConfiguration.java b/student-service/src/main/java/com/javatab/student/MessageFunctionConfiguration.java
index 7f34164..31b50e7 100644
--- a/student-service/src/main/java/com/javatab/student/MessageFunctionConfiguration.java
+++ b/student-service/src/main/java/com/javatab/student/MessageFunctionConfiguration.java
@@ -1,5 +1,7 @@
 package com.javatab.student;
 
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.stream.function.StreamBridge;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -8,8 +10,18 @@
 @Configuration
 public class MessageFunctionConfiguration {
 
+    @Autowired
+    private StreamBridge streamBridge;
+
+    static final String STUDENT_CREATED_OUTPUT = "studentCreatedOutput";
+
     @Bean
     Consumer<UserEvent> getNewlyCreatedUser() {
-        return userEvent -> System.out.println("New created user " + userEvent);
+        return userEvent -> {
+            System.out.println("New created user " + userEvent);
+            Student student = Student.builder().username(userEvent.getUsername()).build();
+            boolean isSent = streamBridge.send(STUDENT_CREATED_OUTPUT, student);
+            System.out.println("Is sent " + isSent);
+        };
     }
 }
diff --git a/student-service/src/main/java/com/javatab/student/StudentController.java b/student-service/src/main/java/com/javatab/student/StudentController.java
index 267a666..3e3847e 100644
--- a/student-service/src/main/java/com/javatab/student/StudentController.java
+++ b/student-service/src/main/java/com/javatab/student/StudentController.java
@@ -1,6 +1,7 @@
 package com.javatab.student;
 
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.stream.function.StreamBridge;
 import org.springframework.web.bind.annotation.*;
 
 @RestController
diff --git a/student-service/src/main/resources/application.yml b/student-service/src/main/resources/application.yml
index e28b0a8..54bbe0b 100644
--- a/student-service/src/main/resources/application.yml
+++ b/student-service/src/main/resources/application.yml
@@ -10,9 +10,9 @@ spring:
         service-id: config-server
 
     stream:
-     # kafka:
-      #  binder:
-       #   brokers: 192.168.1.8
+      kafka:
+        binder:
+          brokers: kafka
       #function:
        # defination: getNewlyCreatedUser
       bindings:
@@ -20,6 +20,8 @@ spring:
           destination: userCreatedOutput
           #binder: kafka
           group: mygroup
+        studentCreatedOutput-out-0:
+          destination: studentCreatedOutput
   data:
     mongodb:
       host: localhost