From: Kai Moritz <kai@juplo.de>
Date: Sat, 13 Aug 2022 16:21:40 +0000 (+0200)
Subject: In dieser Version nicht benötigten Parameter `partition` entfernt.
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=431c25592ccb804bccaa59db0eea68e247535eb4;p=demos%2Fkafka%2Ftraining

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
--- 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
--- 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<>();