In dieser Version nicht benötigten Parameter `partition` entfernt.

diff --git a/src/main/java/de/juplo/kafka/ApplicationProperties.java b/src/main/java/de/juplo/kafka/ApplicationProperties.java
index 673613a..e8691f0 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationProperties.java
+++ b/src/main/java/de/juplo/kafka/ApplicationProperties.java
@@ -22,9 +22,6 @@ public class ApplicationProperties
   @NotNull
   @NotEmpty
   private String topic;
-  private Integer partition;
-  @NotNull
-  @NotEmpty
   private String acks;
   @NotNull
   private Integer batchSize;

diff --git a/src/main/java/de/juplo/kafka/RestProducer.java b/src/main/java/de/juplo/kafka/RestProducer.java
index 0467118..93dfef6 100644 (file)
--- a/src/main/java/de/juplo/kafka/RestProducer.java
+++ b/src/main/java/de/juplo/kafka/RestProducer.java
@@ -20,7 +20,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;
@@ -29,7 +28,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<>();