diff --git a/src/main/java/io/debezium/connector/informix/InformixStreamingChangeEventSource.java b/src/main/java/io/debezium/connector/informix/InformixStreamingChangeEventSource.java
index 63ca5c7..f5b0226 100644
--- a/src/main/java/io/debezium/connector/informix/InformixStreamingChangeEventSource.java
+++ b/src/main/java/io/debezium/connector/informix/InformixStreamingChangeEventSource.java
@@ -129,6 +129,10 @@ public void execute(ChangeEventSourceContext context, InformixPartition partitio
                     dispatcher.dispatchHeartbeatEvent(partition, offsetContext);
 
                     IfmxStreamRecord streamRecord = transactionEngine.getRecord();
+                    if (streamRecord == null) {
+                        LOGGER.debug(RECEIVED_GENERIC_RECORD, streamRecord, 0);
+                        continue;
+                    }
 
                     switch (streamRecord.getType()) {
                         case TRANSACTION_GROUP:
@@ -183,6 +187,10 @@ public void execute(ChangeEventSourceContext context, InformixPartition partitio
                 dispatcher.dispatchHeartbeatEvent(partition, offsetContext);
 
                 IfmxStreamRecord streamRecord = transactionEngine.getRecord();
+                if (streamRecord == null) {
+                    LOGGER.debug(RECEIVED_GENERIC_RECORD, streamRecord, 0);
+                    continue;
+                }
 
                 switch (streamRecord.getType()) {
                     case TRANSACTION_GROUP: