diff --git a/2024-09/spring-38-kafka-webflux/processor/src/main/java/com/datasrc/config/ApplConfig.java b/2024-09/spring-38-kafka-webflux/processor/src/main/java/com/datasrc/config/ApplConfig.java
index 14ca7d67..c271c1fa 100755
--- a/2024-09/spring-38-kafka-webflux/processor/src/main/java/com/datasrc/config/ApplConfig.java
+++ b/2024-09/spring-38-kafka-webflux/processor/src/main/java/com/datasrc/config/ApplConfig.java
@@ -25,7 +25,6 @@ import org.springframework.web.reactive.function.client.WebClient;
 import reactor.core.scheduler.Scheduler;
 import reactor.core.scheduler.Schedulers;
 import reactor.util.annotation.NonNull;
-import reactor.util.annotation.Nullable;
 
 @Configuration
 @SuppressWarnings("java:S2095")
diff --git a/2024-09/spring-38-kafka-webflux/source/src/main/java/com/datasrc/config/ApplConfig.java b/2024-09/spring-38-kafka-webflux/source/src/main/java/com/datasrc/config/ApplConfig.java
index c007fb55..7186ef9a 100755
--- a/2024-09/spring-38-kafka-webflux/source/src/main/java/com/datasrc/config/ApplConfig.java
+++ b/2024-09/spring-38-kafka-webflux/source/src/main/java/com/datasrc/config/ApplConfig.java
@@ -1,7 +1,7 @@
 package com.datasrc.config;
 
 import io.netty.channel.nio.NioEventLoopGroup;
-import java.util.concurrent.Executor;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
 import org.springframework.beans.factory.annotation.Qualifier;
@@ -43,7 +43,7 @@ public class ApplConfig {
     }
 
     @Bean(name= "blockingExecutor", destroyMethod = "close")
-    public Executor blockingExecutor() {
+    public ExecutorService blockingExecutor() {
         var id = new AtomicLong(0);
         return Executors.newFixedThreadPool(BLOCKING_THREAD_POOL_SIZE,
                 task -> new Thread(task, String.format("blocking-thread-%d", id.incrementAndGet())));