recorder:1.0.0 - send recordings keyed by username recorder-1.0.0
authorKai Moritz <kai@juplo.de>
Wed, 1 Sep 2021 16:42:29 +0000 (18:42 +0200)
committerKai Moritz <kai@juplo.de>
Sat, 4 Sep 2021 11:29:05 +0000 (13:29 +0200)
.dockerignore [new file with mode: 0644]
Dockerfile [new file with mode: 0644]
pom.xml
src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplication.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationProperties.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/wordcount/recorder/RecordingResult.java [new file with mode: 0644]
src/main/java/de/juplo/kafka/wordcount/recorder/WordcountRecorderApplication.java [deleted file]
src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java [new file with mode: 0644]
src/test/java/de/juplo/kafka/wordcount/recorder/WordcountRecorderApplicationTests.java [deleted file]

diff --git a/.dockerignore b/.dockerignore
new file mode 100644 (file)
index 0000000..1ad9963
--- /dev/null
@@ -0,0 +1,2 @@
+*
+!target/*.jar
diff --git a/Dockerfile b/Dockerfile
new file mode 100644 (file)
index 0000000..bbd15ef
--- /dev/null
@@ -0,0 +1,5 @@
+FROM openjdk:11-jre-slim
+COPY target/*.jar /opt/app.jar
+EXPOSE 8080
+ENTRYPOINT ["java", "-jar", "/opt/app.jar"]
+CMD []
diff --git a/pom.xml b/pom.xml
index 6dfd615..98cc0dc 100644 (file)
--- a/pom.xml
+++ b/pom.xml
        </parent>
        <groupId>de.juplo.kafka.wordcount</groupId>
        <artifactId>recorder</artifactId>
-       <version>0.0.1-SNAPSHOT</version>
+       <version>1.0.0</version>
        <name>Wordcount-Recorder</name>
        <description>Recorder-service of the multi-user wordcount-example</description>
        <properties>
+               <docker-maven-plugin.version>0.33.0</docker-maven-plugin.version>
                <java.version>11</java.version>
+               <kafka.version>2.8.0</kafka.version>
        </properties>
        <dependencies>
                <dependency>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter-web</artifactId>
                </dependency>
+               <dependency>
+                       <groupId>org.apache.kafka</groupId>
+                       <artifactId>kafka-clients</artifactId>
+               </dependency>
+               <dependency>
+                       <groupId>org.hibernate.validator</groupId>
+                       <artifactId>hibernate-validator</artifactId>
+               </dependency>
 
                <dependency>
                        <groupId>org.springframework.boot</groupId>
                                        </excludes>
                                </configuration>
                        </plugin>
+                       <plugin>
+                               <groupId>io.fabric8</groupId>
+                               <artifactId>docker-maven-plugin</artifactId>
+                               <version>${docker-maven-plugin.version}</version>
+                               <configuration>
+                                       <images>
+                                               <image>
+                                                       <name>juplo/wordcount--%a:%v</name>
+                                               </image>
+                                       </images>
+                               </configuration>
+                       </plugin>
                </plugins>
        </build>
 
diff --git a/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplication.java b/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplication.java
new file mode 100644 (file)
index 0000000..abe0685
--- /dev/null
@@ -0,0 +1,36 @@
+package de.juplo.kafka.wordcount.recorder;
+
+import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerConfig;
+import org.apache.kafka.common.serialization.StringSerializer;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.util.Assert;
+
+import java.util.Properties;
+
+
+@SpringBootApplication
+@EnableConfigurationProperties(RecorderApplicationProperties.class)
+public class RecorderApplication
+{
+       @Bean(destroyMethod = "close")
+       KafkaProducer<String, String> producer(RecorderApplicationProperties properties)
+       {
+               Assert.hasText(properties.getBootstrapServer(), "juplo.wordcount.recorder.bootstrap-server must be set");
+
+               Properties props = new Properties();
+               props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, properties.getBootstrapServer());
+               props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
+               props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
+
+               return new KafkaProducer<>(props);
+       }
+
+       public static void main(String[] args)
+       {
+               SpringApplication.run(RecorderApplication.class, args);
+       }
+}
diff --git a/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationProperties.java b/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationProperties.java
new file mode 100644 (file)
index 0000000..552ebaf
--- /dev/null
@@ -0,0 +1,18 @@
+package de.juplo.kafka.wordcount.recorder;
+
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+
+@ConfigurationProperties("juplo.wordcount.recorder")
+@Getter
+@Setter
+@ToString
+public class RecorderApplicationProperties
+{
+  private String bootstrapServer = "localhost:9092";
+  private String topic = "recordings";
+}
diff --git a/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java b/src/main/java/de/juplo/kafka/wordcount/recorder/RecorderController.java
new file mode 100644 (file)
index 0000000..5fe69ad
--- /dev/null
@@ -0,0 +1,80 @@
+package de.juplo.kafka.wordcount.recorder;
+
+import org.apache.kafka.clients.producer.KafkaProducer;
+import org.apache.kafka.clients.producer.ProducerRecord;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.util.MimeTypeUtils;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.context.request.async.DeferredResult;
+
+import javax.validation.constraints.NotEmpty;
+
+
+@RestController
+public class RecorderController
+{
+  private final String topic;
+  private final KafkaProducer<String, String> producer;
+
+
+  public RecorderController(RecorderApplicationProperties properties, KafkaProducer<String,String> producer)
+  {
+    this.topic = properties.getTopic();
+    this.producer = producer;
+  }
+
+  @PostMapping(
+      path = "/{username}",
+      consumes = {
+          MimeTypeUtils.TEXT_PLAIN_VALUE,
+          MimeTypeUtils.APPLICATION_JSON_VALUE
+      },
+      produces = MimeTypeUtils.APPLICATION_JSON_VALUE)
+  DeferredResult<ResponseEntity<RecordingResult>> speak(
+      @PathVariable
+      @NotEmpty(message = "A username must be provided")
+      String username,
+      @RequestBody
+      @NotEmpty(message = "The spoken sentence must not be empty!")
+      String sentence)
+  {
+    DeferredResult<ResponseEntity<RecordingResult>> result = new DeferredResult<>();
+
+    ProducerRecord<String, String> record = new ProducerRecord<>(topic, username, sentence);
+    producer.send(record, (metadata, exception) ->
+    {
+      if (metadata != null)
+      {
+        result.setResult(
+            ResponseEntity.ok(RecordingResult.of(
+                username,
+                sentence,
+                topic,
+                metadata.partition(),
+                metadata.offset(),
+                null,
+                null)));
+      }
+      else
+      {
+        result.setErrorResult(
+            ResponseEntity
+                .internalServerError()
+                .body(RecordingResult.of(
+                    username,
+                    sentence,
+                    topic,
+                    null,
+                    null,
+                    HttpStatus.INTERNAL_SERVER_ERROR.value(),
+                    exception.toString())));
+      }
+    });
+
+    return result;
+  }
+}
diff --git a/src/main/java/de/juplo/kafka/wordcount/recorder/RecordingResult.java b/src/main/java/de/juplo/kafka/wordcount/recorder/RecordingResult.java
new file mode 100644 (file)
index 0000000..939b1d4
--- /dev/null
@@ -0,0 +1,19 @@
+package de.juplo.kafka.wordcount.recorder;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import lombok.Value;
+
+import static com.fasterxml.jackson.annotation.JsonInclude.Include.NON_NULL;
+
+
+@Value(staticConstructor = "of")
+public class RecordingResult
+{
+  @JsonInclude(NON_NULL) private final String username;
+  @JsonInclude(NON_NULL) private final String sentence;
+  @JsonInclude(NON_NULL) private final String topic;
+  @JsonInclude(NON_NULL) private final Integer partition;
+  @JsonInclude(NON_NULL) private final Long offset;
+  @JsonInclude(NON_NULL) private final Integer status;
+  @JsonInclude(NON_NULL) private final String error;
+}
diff --git a/src/main/java/de/juplo/kafka/wordcount/recorder/WordcountRecorderApplication.java b/src/main/java/de/juplo/kafka/wordcount/recorder/WordcountRecorderApplication.java
deleted file mode 100644 (file)
index 8220bfd..0000000
+++ /dev/null
@@ -1,13 +0,0 @@
-package de.juplo.kafka.wordcount.recorder;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-
-@SpringBootApplication
-public class WordcountRecorderApplication
-{
-       public static void main(String[] args)
-       {
-               SpringApplication.run(WordcountRecorderApplication.class, args);
-       }
-}
diff --git a/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java b/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java
new file mode 100644 (file)
index 0000000..885a408
--- /dev/null
@@ -0,0 +1,13 @@
+package de.juplo.kafka.wordcount.recorder;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class ApplicationTests
+{
+       @Test
+       void contextLoads()
+       {
+       }
+}
diff --git a/src/test/java/de/juplo/kafka/wordcount/recorder/WordcountRecorderApplicationTests.java b/src/test/java/de/juplo/kafka/wordcount/recorder/WordcountRecorderApplicationTests.java
deleted file mode 100644 (file)
index 8b8aa50..0000000
+++ /dev/null
@@ -1,13 +0,0 @@
-package de.juplo.kafka.wordcount.recorder;
-
-import org.junit.jupiter.api.Test;
-import org.springframework.boot.test.context.SpringBootTest;
-
-@SpringBootTest
-class WordcountRecorderApplicationTests
-{
-       @Test
-       void contextLoads()
-       {
-       }
-}