From 415da1f1bc4feb6e2f7cc12b31c967d93677d224 Mon Sep 17 00:00:00 2001
From: Rohan <rohan.anil.kumar1@ibm.com>
Date: Mon, 15 Jun 2026 12:31:03 +0530
Subject: [PATCH 1/3] feat: pause Kafka consumer on subscription until start
 command

Contributes to: #392

Signed-off-by: Rohan <rohan.anil.kumar1@ibm.com>
---
 src/main/java/kafka/vertx/demo/WebSocketServer.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/main/java/kafka/vertx/demo/WebSocketServer.java b/src/main/java/kafka/vertx/demo/WebSocketServer.java
index 76dd7c5..fc4f47c 100644
--- a/src/main/java/kafka/vertx/demo/WebSocketServer.java
+++ b/src/main/java/kafka/vertx/demo/WebSocketServer.java
@@ -153,6 +153,8 @@ private void handleConsumeSocket(ServerWebSocket webSocket) {
     kafkaConsumer.subscribe(topic)
         .onSuccess(v -> {
           logger.info("Subscribed to {}", topic);
+          kafkaConsumer.pause();
+          logger.info("Consumer paused, waiting for start command");
         })
         .onFailure(err -> logger.error("Could not subscribe to {}", topic, err));
 

From 5c064d0369335da07c8a81d8e9bedfd4a2518f96 Mon Sep 17 00:00:00 2001
From: Rohan <rohan.anil.kumar1@ibm.com>
Date: Mon, 15 Jun 2026 15:13:10 +0530
Subject: [PATCH 2/3] chore: bump version from 1.1.5 to 1.1.6

Contributes to: #392

Signed-off-by: Rohan <rohan.anil.kumar1@ibm.com>
---
 pom.xml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index dca8da8..bd901cb 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
 
   <groupId>kafka.vertx</groupId>
   <artifactId>demo</artifactId>
-  <version>1.1.5</version>
+  <version>1.1.6</version>
 
   <properties>
     <vertx.version>5.1.0</vertx.version>

From 0449e35cf00b7d379897ca3d3d85ab8d3a5461a1 Mon Sep 17 00:00:00 2001
From: Rohan <rohan.anil.kumar1@ibm.com>
Date: Tue, 16 Jun 2026 10:40:24 +0530
Subject: [PATCH 3/3] refactor: remove redundant consumer pause log message

Contributes to: #392

Signed-off-by: Rohan <rohananilpnr@gmail.com>
---
 src/main/java/kafka/vertx/demo/WebSocketServer.java | 1 -
 1 file changed, 1 deletion(-)

diff --git a/src/main/java/kafka/vertx/demo/WebSocketServer.java b/src/main/java/kafka/vertx/demo/WebSocketServer.java
index fc4f47c..343be6f 100644
--- a/src/main/java/kafka/vertx/demo/WebSocketServer.java
+++ b/src/main/java/kafka/vertx/demo/WebSocketServer.java
@@ -154,7 +154,6 @@ private void handleConsumeSocket(ServerWebSocket webSocket) {
         .onSuccess(v -> {
           logger.info("Subscribed to {}", topic);
           kafkaConsumer.pause();
-          logger.info("Consumer paused, waiting for start command");
         })
         .onFailure(err -> logger.error("Could not subscribe to {}", topic, err));