kafka sample

fdanismaz · fdanismaz · commit 1aea3d112aea · 2019-05-28T05:08:49.000+03:00
diff --git a/kafka-sample/pom.xml b/kafka-sample/pom.xml
@@ -0,0 +1,42 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+		 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+		 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+
+	<groupId>com.fd</groupId>
+	<artifactId>kafka-sample</artifactId>
+	<version>1.0-SNAPSHOT</version>
+
+	<properties>
+		<java-version>1.8</java-version>
+		<maven.compiler.source>1.8</maven.compiler.source>
+		<maven.compiler.target>1.8</maven.compiler.target>
+	</properties>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>2.1.4.RELEASE</version>
+	</parent>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.projectlombok</groupId>
+			<artifactId>lombok</artifactId>
+			<version>1.18.4</version>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.kafka</groupId>
+			<artifactId>spring-kafka</artifactId>
+		</dependency>
+
+	</dependencies>
+
+</project>
diff --git a/kafka-sample/src/main/java/com/fd/kafka/App.java b/kafka-sample/src/main/java/com/fd/kafka/App.java
@@ -0,0 +1,17 @@
+package com.fd.kafka;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * @author fdanismaz
+ * date: 5/1/19 2:03 PM
+ */
+@SpringBootApplication
+public class App {
+
+	public static void main(String[] args) {
+		SpringApplication.run(App.class);
+	}
+
+}
diff --git a/kafka-sample/src/main/java/com/fd/kafka/controller/ProducerController.java b/kafka-sample/src/main/java/com/fd/kafka/controller/ProducerController.java
@@ -0,0 +1,26 @@
+package com.fd.kafka.controller;
+
+import com.fd.kafka.service.Producer;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author fdanismaz
+ * date: 5/1/19 2:09 PM
+ */
+@RestController
+@RequestMapping("/producer")
+public class ProducerController {
+
+	@Autowired
+	private Producer producer;
+
+	@GetMapping("/heartbeat")
+	public ResponseEntity<Boolean> heartbeat() {
+		this.producer.sendMessage("test", "heartbeat", "up");
+		return ResponseEntity.ok(true);
+	}
+}
diff --git a/kafka-sample/src/main/java/com/fd/kafka/service/Producer.java b/kafka-sample/src/main/java/com/fd/kafka/service/Producer.java
@@ -0,0 +1,21 @@
+package com.fd.kafka.service;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.kafka.core.KafkaTemplate;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author fdanismaz
+ * date: 5/1/19 2:14 PM
+ */
+@Service
+public class Producer {
+
+	@Autowired
+	private KafkaTemplate<String, String> kafkaTemplate;
+
+	public void sendMessage(String topic, String key, String message) {
+		this.kafkaTemplate.send(topic, key, message);
+	}
+
+}
diff --git a/kafka-sample/src/main/resources/application.properties b/kafka-sample/src/main/resources/application.properties
@@ -0,0 +1,11 @@
+#spring.datasource.driver-class-name=com.mysql.jdbc.Driver
+#spring.datasource.url=jdbc:mysql://localhost:3306/bookstore
+#spring.datasource.username=root
+#spring.datasource.password=123456
+#spring.jpa.hibernate.ddl-auto=none
+#spring.jpa.show-sql=true
+#spring.jpa.generate-ddl=true
+
+spring.kafka.producer.bootstrap-servers = localhost:9092
+spring.kafka.producer.key-serializer    = org.apache.kafka.common.serialization.StringSerializer
+spring.kafka.producer.value-serializer  = org.apache.kafka.common.serialization.StringSerializer
