From 6387482ee8a772327978dcef50c4b5ccbfe68c76 Mon Sep 17 00:00:00 2001 From: Struchkov Mark Date: Wed, 9 Nov 2022 16:55:30 +0300 Subject: [PATCH] =?UTF-8?q?=D0=9E=D0=B1=D0=BD=D0=BE=D0=B2=D0=B8=D0=BB=20?= =?UTF-8?q?=D0=B2=D0=B5=D1=80=D1=81=D0=B8=D1=8E=20=D0=BA=D0=B2=D0=B0=D1=80?= =?UTF-8?q?=D0=BA=D1=83=D1=81=D0=B0=20=D0=B4=D0=BE=202.14.0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../example/quarkus/generator/KafkaMessageGenerator.java | 2 +- quarkus-kafka-panache-problem/pom.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/quarkus-kafka-panache-generator/src/main/java/dev/struchkov/example/quarkus/generator/KafkaMessageGenerator.java b/quarkus-kafka-panache-generator/src/main/java/dev/struchkov/example/quarkus/generator/KafkaMessageGenerator.java index 94c331e..dad2c60 100644 --- a/quarkus-kafka-panache-generator/src/main/java/dev/struchkov/example/quarkus/generator/KafkaMessageGenerator.java +++ b/quarkus-kafka-panache-generator/src/main/java/dev/struchkov/example/quarkus/generator/KafkaMessageGenerator.java @@ -21,7 +21,7 @@ public class KafkaMessageGenerator { public void start(@Observes StartupEvent ev) { - for (int i = 0; i < 20; i++) { + for (int i = 0; i < 50; i++) { final KafkaMessage kafkaMessage = new KafkaMessage(); kafkaMessage.setCount(i); telegramChannel.sendAndAwait(kafkaMessage); diff --git a/quarkus-kafka-panache-problem/pom.xml b/quarkus-kafka-panache-problem/pom.xml index 009e42d..e6baba8 100644 --- a/quarkus-kafka-panache-problem/pom.xml +++ b/quarkus-kafka-panache-problem/pom.xml @@ -15,7 +15,7 @@ UTF-8 quarkus-bom io.quarkus.platform - 2.11.2.Final + 2.14.0.Final true 3.0.0-M7