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 673613a840f2768af3cb9cf04b6c8e7efb39e584..e8691f0e279acc3450e62e52880f29eec0ca91ba 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 04671189572dad072eda5d0577dc42c8e4e66781..93dfef62b3c95b9a58134637ca7ccfcc69d5a387 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<>();