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