chore(demo-kafka): fix org.apache.kafka.common.errors.TimeoutException

Author: helltractor

demo-kafka/src/test/java/com/helltractor/demo/container/ConfluentKafkaContainerCluster.java

@@ -39,7 +39,7 @@ public ConfluentKafkaContainerCluster(String confluentPlatformVersion, int broke
 
         String controllerQuorumVoters = IntStream
                 .range(0, brokersNum)
-                .mapToObj(brokerNum -> String.format("%d@broker-%d:9094", brokerNum, brokerNum))
+                .mapToObj(brokerNum -> String.format("%d@broker-%d:9092", brokerNum, brokerNum))
                 .collect(Collectors.joining(","));
 
         String clusterId = Uuid.randomUuid().toString();

demo-kafka/src/test/java/com/helltractor/demo/messaging/MessagingFactoryTest.java

@@ -53,7 +53,7 @@ int getTotalMessages() {
 
     @BeforeEach
     void init() {
-        cluster = new ConfluentKafkaContainerCluster("7.4.0", 1, 1);
+        cluster = new ConfluentKafkaContainerCluster("7.4.0", 3, 2);
         cluster.start();
         Awaitility.await()
                 .atMost(Duration.ofMinutes(1))