From 431c25592ccb804bccaa59db0eea68e247535eb4 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sat, 13 Aug 2022 18:21:40 +0200 Subject: [PATCH] =?utf8?q?In=20dieser=20Version=20nicht=20ben=C3=B6tigten?= =?utf8?q?=20Parameter=20`partition`=20entfernt.?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- src/main/java/de/juplo/kafka/ApplicationProperties.java | 3 --- src/main/java/de/juplo/kafka/RestProducer.java | 3 +-- 2 files changed, 1 insertion(+), 5 deletions(-) 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 producer; private long produced = 0; @@ -29,7 +28,7 @@ public class RestProducer public DeferredResult send( @PathVariable String key, @RequestHeader(name = "X-id", required = false) Long correlationId, - @RequestBody String value) + @RequestBody Integer value) { DeferredResult result = new DeferredResult<>(); -- 2.20.1