diff --git a/.github/workflows/fvt-main.yml b/.github/workflows/fvt-main.yml
index f00d9531b..bef01bd71 100644
--- a/.github/workflows/fvt-main.yml
+++ b/.github/workflows/fvt-main.yml
@@ -21,7 +21,7 @@ jobs:
       fail-fast: false
       matrix:
         go-version: [stable]
-        kafka-version: [1.0.2, 2.0.1, 2.2.2, 2.6.3, 2.8.2, 3.0.2, 3.3.2, 3.6.2, 3.8.1, 4.0.0, 4.1.1]
+        kafka-version: [1.0.2, 2.0.1, 2.2.2, 2.6.3, 2.8.2, 3.0.2, 3.3.2, 3.6.2, 3.8.1, 3.9.1, 4.0.1, 4.1.1]
         include:
         - kafka-version: 1.0.2
           scala-version: 2.11
@@ -41,7 +41,9 @@ jobs:
           scala-version: 2.13
         - kafka-version: 3.8.1
           scala-version: 2.13
-        - kafka-version: 4.0.0
+        - kafka-version: 3.9.1
+          scala-version: 2.13
+        - kafka-version: 4.0.1
           scala-version: 2.13
         - kafka-version: 4.1.1
           scala-version: 2.13
diff --git a/.github/workflows/fvt-pr.yml b/.github/workflows/fvt-pr.yml
index c862609e1..564065670 100644
--- a/.github/workflows/fvt-pr.yml
+++ b/.github/workflows/fvt-pr.yml
@@ -20,7 +20,7 @@ jobs:
       fail-fast: false
       matrix:
         go-version: [stable]
-        kafka-version: [1.0.2, 2.6.3, 3.6.2, 3.9.1, 4.1.1]
+        kafka-version: [1.0.2, 2.6.3, 3.6.2, 3.9.1, 4.0.1, 4.1.1]
         include:
         - kafka-version: 1.0.2
           scala-version: 2.11
@@ -30,6 +30,8 @@ jobs:
           scala-version: 2.13
         - kafka-version: 3.9.1
           scala-version: 2.13
+        - kafka-version: 4.0.1
+          scala-version: 2.13
         - kafka-version: 4.1.1
           scala-version: 2.13
     uses: ./.github/workflows/fvt.yml
diff --git a/utils.go b/utils.go
index f683dc01d..27790bef0 100644
--- a/utils.go
+++ b/utils.go
@@ -216,6 +216,7 @@ var (
 	V3_9_0_0  = newKafkaVersion(3, 9, 0, 0)
 	V3_9_1_0  = newKafkaVersion(3, 9, 1, 0)
 	V4_0_0_0  = newKafkaVersion(4, 0, 0, 0)
+	V4_0_1_0  = newKafkaVersion(4, 0, 1, 0)
 	V4_1_0_0  = newKafkaVersion(4, 1, 0, 0)
 	V4_1_1_0  = newKafkaVersion(4, 1, 1, 0)
 
@@ -292,6 +293,7 @@ var (
 		V3_9_0_0,
 		V3_9_1_0,
 		V4_0_0_0,
+		V4_0_1_0,
 		V4_1_0_0,
 		V4_1_1_0,
 	}