WIP

diff --git a/pom.xml b/pom.xml
index e4d24bb..ae66c2b 100644 (file)
--- a/pom.xml
+++ b/pom.xml
@@ -12,9 +12,9 @@
   </parent>
 
   <groupId>de.juplo.kafka</groupId>
-  <artifactId>rest-producer</artifactId>
-  <name>REST Producer</name>
-  <description>A Simple Producer that takes messages via POST and confirms successs</description>
+  <artifactId>sumup-producer</artifactId>
+  <name>SumUp-Producer</name>
+  <description>A Producer that reads computation requests from an incomming topic and generates according messages for the SumUp-Consumer on an outgoing topic</description>
   <version>1.0-SNAPSHOT</version>
 
   <dependencies>

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
new file mode 100644 (file)
index 0000000..d2d8cbb
--- /dev/null
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -0,0 +1,9 @@
+package de.juplo.kafka;
+
+import org.springframework.context.annotation.Configuration;
+
+
+@Configuration
+public class ApplicationConfiguration
+{
+}

diff --git a/src/main/java/de/juplo/kafka/ApplicationProperties.java b/src/main/java/de/juplo/kafka/ApplicationProperties.java
index c74f588..1f30262 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationProperties.java
+++ b/src/main/java/de/juplo/kafka/ApplicationProperties.java
@@ -12,7 +12,6 @@ public class ApplicationProperties
   private String bootstrapServer;
   private String clientId;
   private String topic;
-  private Integer partition;
   private String acks;
   private Integer batchSize;
   private Integer lingerMs;

diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java
index 59d2c77..56f2bb1 100644 (file)
--- a/src/main/java/de/juplo/kafka/RestProducer.java
+++ b/src/main/java/de/juplo/kafka/RestProducer.java
@@ -19,7 +19,6 @@ public class RestProducer
 {
   private final String id;
   private final String topic;
-  private final Integer partition;
   private final KafkaProducer<String, String> producer;
 
   private long produced = 0;
@@ -28,7 +27,6 @@ public class RestProducer
   {
     this.id = properties.getClientId();
     this.topic = properties.getTopic();
-    this.partition = properties.getPartition();
 
     Properties props = new Properties();
     props.put("bootstrap.servers", properties.getBootstrapServer());
@@ -49,7 +47,7 @@ public class RestProducer
   public DeferredResult<ProduceResult> send(
       @PathVariable String key,
       @RequestHeader(name = "X-id", required = false) Long correlationId,
-      @RequestBody String value)
+      @RequestBody Integer value)
   {
     DeferredResult<ProduceResult> result = new DeferredResult<>();