From fe5196ac473fe673758f9407b54f8ee7251b5ffe Mon Sep 17 00:00:00 2001
From: Jakub Cechacek <jcechace@gmail.com>
Date: Wed, 14 Aug 2024 11:56:43 +0200
Subject: [PATCH] DBZ-8135 InProcessSignalChannel#read() returns empty list
 when channel is closed

---
 .../signal/channels/process/InProcessSignalChannel.java        | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/debezium-core/src/main/java/io/debezium/pipeline/signal/channels/process/InProcessSignalChannel.java b/debezium-core/src/main/java/io/debezium/pipeline/signal/channels/process/InProcessSignalChannel.java
index 6f1d7c051..1df681a54 100644
--- a/debezium-core/src/main/java/io/debezium/pipeline/signal/channels/process/InProcessSignalChannel.java
+++ b/debezium-core/src/main/java/io/debezium/pipeline/signal/channels/process/InProcessSignalChannel.java
@@ -49,6 +49,9 @@ public void init(CommonConnectorConfig connectorConfig) {
 
     @Override
     public List<SignalRecord> read() {
+        if (!open.get()) {
+            return List.of();
+        }
         return Stream.ofNullable(signals.poll()).toList();
     }