DBZ-8948 Add polling start and stop events

Author: vjuranek

debezium-server-core/src/main/java/io/debezium/server/ConnectorLifecycle.java

@@ -5,6 +5,8 @@
  */
 package io.debezium.server;
 
+import io.debezium.server.events.PollingStartedEvent;
+import io.debezium.server.events.PollingStoppedEvent;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.enterprise.event.Event;
 import jakarta.inject.Inject;
@@ -49,6 +51,12 @@ public class ConnectorLifecycle implements HealthCheck, DebeziumEngine.Connector
     @Inject
     Event<TaskStoppedEvent> taskStoppedEvent;
 
+    @Inject
+    Event<PollingStartedEvent> pollingStartedEvent;
+
+    @Inject
+    Event<PollingStoppedEvent> pollingStoppedEvent;
+
     @Inject
     Event<ConnectorCompletedEvent> connectorCompletedEvent;
 
@@ -77,6 +85,18 @@ public void taskStopped() {
         taskStoppedEvent.fire(new TaskStoppedEvent());
     }
 
+    @Override
+    public void pollingStarted() {
+        LOGGER.debug("Polling started");
+        pollingStartedEvent.fire(new PollingStartedEvent());
+    }
+
+    @Override
+    public void pollingStopped() {
+        LOGGER.debug("Polling stopped");
+        pollingStoppedEvent.fire(new PollingStoppedEvent());
+    }
+
     @Override
     public void handle(boolean success, String message, Throwable error) {
         String logMessage = String.format("Connector completed: success = '%s', message = '%s', error = '%s'", success, message, error);

debezium-server-core/src/main/java/io/debezium/server/events/PollingStartedEvent.java

@@ -0,0 +1,9 @@
+package io.debezium.server.events;
+
+/**
+ * Fired right before creating polling loop.
+ *
+ * @author vjuranek
+ */
+public class PollingStartedEvent {
+}

debezium-server-core/src/main/java/io/debezium/server/events/PollingStoppedEvent.java

@@ -0,0 +1,9 @@
+package io.debezium.server.events;
+
+/**
+ * Fired once the polling loop is finished.
+ *
+ * @author vjuranek
+ */
+public class PollingStoppedEvent {
+}