diff --git a/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/dsl/package-info.java b/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/dsl/package-info.java
index 3df2a6ea52d..9d50185210f 100644
--- a/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/dsl/package-info.java
+++ b/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/dsl/package-info.java
@@ -1,6 +1,5 @@
 /**
  * Provides classes for supporting Debezium component via Java DSL.
  */
-@org.springframework.lang.NonNullApi
-@org.springframework.lang.NonNullFields
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.debezium.dsl;
diff --git a/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/inbound/DebeziumMessageProducer.java b/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/inbound/DebeziumMessageProducer.java
index 07892003b47..1d090b30581 100644
--- a/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/inbound/DebeziumMessageProducer.java
+++ b/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/inbound/DebeziumMessageProducer.java
@@ -31,13 +31,13 @@
 import io.debezium.engine.DebeziumEngine.RecordCommitter;
 import io.debezium.engine.Header;
 import io.debezium.engine.format.SerializationFormat;
+import org.jspecify.annotations.Nullable;
 
 import org.springframework.core.task.SimpleAsyncTaskExecutor;
 import org.springframework.core.task.TaskExecutor;
 import org.springframework.integration.debezium.support.DebeziumHeaders;
 import org.springframework.integration.debezium.support.DefaultDebeziumHeaderMapper;
 import org.springframework.integration.endpoint.MessageProducerSupport;
-import org.springframework.lang.Nullable;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.MessageHeaders;
 import org.springframework.messaging.support.HeaderMapper;
@@ -55,11 +55,13 @@ public class DebeziumMessageProducer extends MessageProducerSupport {
 
 	private final DebeziumEngine.Builder<ChangeEvent<byte[], byte[]>> debeziumEngineBuilder;
 
+	@SuppressWarnings("NullAway.Init")
 	private DebeziumEngine<ChangeEvent<byte[], byte[]>> debeziumEngine;
 
 	/**
 	 * Debezium Engine is designed to be submitted to an {@link Executor}.
 	 */
+	@SuppressWarnings("NullAway.Init")
 	private TaskExecutor taskExecutor;
 
 	private String contentType = "application/json";
diff --git a/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/inbound/package-info.java b/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/inbound/package-info.java
index 69eb77dc7a2..a326b6afe4b 100644
--- a/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/inbound/package-info.java
+++ b/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/inbound/package-info.java
@@ -1,5 +1,5 @@
 /**
  * Provides classes for the Debezium inbound channel adapters.
  */
-@org.springframework.lang.NonNullApi
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.debezium.inbound;
diff --git a/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/support/package-info.java b/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/support/package-info.java
index 209a2958527..e6249909e93 100644
--- a/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/support/package-info.java
+++ b/spring-integration-debezium/src/main/java/org/springframework/integration/debezium/support/package-info.java
@@ -1,5 +1,5 @@
 /**
  * Provides supporting classes for the Debezium channel adapters.
  */
-@org.springframework.lang.NonNullApi
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.debezium.support;