diff --git a/Makefile b/Makefile
index 8aa7a87b8b..0d590e1fea 100644
--- a/Makefile
+++ b/Makefile
@@ -79,12 +79,10 @@ build_core: build_prepare
 PLUGINS_IN_FULL := \
 	extensions/sinks/influx \
 	extensions/sinks/influx2 \
-	extensions/sinks/zmq \
 	extensions/sinks/kafka \
 	extensions/sinks/image \
 	extensions/sinks/sql   \
 	extensions/sources/random \
-	extensions/sources/zmq \
 	extensions/sources/sql \
 	extensions/sources/video
 
diff --git a/internal/binder/io/ext_full.go b/internal/binder/io/ext_full.go
index 64f39e0f16..95c8f4cbe6 100644
--- a/internal/binder/io/ext_full.go
+++ b/internal/binder/io/ext_full.go
@@ -22,11 +22,9 @@ import (
 	influx2 "github.com/lf-edge/ekuiper/extensions/sinks/influx2/ext"
 	kafka "github.com/lf-edge/ekuiper/extensions/sinks/kafka/ext"
 	sqlSink "github.com/lf-edge/ekuiper/extensions/sinks/sql/ext"
-	zmqSink "github.com/lf-edge/ekuiper/extensions/sinks/zmq/ext"
 	random "github.com/lf-edge/ekuiper/extensions/sources/random/ext"
 	sql "github.com/lf-edge/ekuiper/extensions/sources/sql/ext"
 	video "github.com/lf-edge/ekuiper/extensions/sources/video/ext"
-	zmq "github.com/lf-edge/ekuiper/extensions/sources/zmq/ext"
 	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
@@ -34,14 +32,14 @@ func init() {
 	sources["random"] = func() api.Source { return random.GetSource() }
 	sources["video"] = func() api.Source { return video.GetSource() }
 	sources["sql"] = func() api.Source { return sql.GetSource() }
-	sources["zmq"] = func() api.Source { return zmq.GetSource() }
 	lookupSources["sql"] = func() api.LookupSource { return sql.GetLookup() }
 	sinks["image"] = func() api.Sink { return image.GetSink() }
 	sinks["influx"] = func() api.Sink { return influx.GetSink() }
 	sinks["influx2"] = func() api.Sink { return influx2.GetSink() }
 	sinks["kafka"] = func() api.Sink { return kafka.GetSink() }
 	sinks["sql"] = func() api.Sink { return sqlSink.GetSink() }
-	// Do not include tdengine because it is not supported for all versions
+	// Do not include zmq/tdengine because it is not supported for all versions
 	// sinks["tdengine"] = func() api.Sink { return tdengine.GetSink() }
-	sinks["zmq"] = func() api.Sink { return zmqSink.GetSink() }
+	// sinks["zmq"] = func() api.Sink { return zmqSink.GetSink() }
+	// sources["zmq"] = func() api.Source { return zmq.GetSource() }
 }
diff --git a/internal/server/prebuild_plugins_full.go b/internal/server/prebuild_plugins_full.go
index 75b6d47ec7..3871710e18 100644
--- a/internal/server/prebuild_plugins_full.go
+++ b/internal/server/prebuild_plugins_full.go
@@ -17,7 +17,7 @@
 package server
 
 var (
-	NativeSourcePlugin   = []string{}
-	NativeSinkPlugin     = []string{"tdengine"}
+	NativeSourcePlugin   = []string{"zmq"}
+	NativeSinkPlugin     = []string{"tdengine", "zmq"}
 	NativeFunctionPlugin = []string{"accumulateWordCount", "countPlusOne", "echo", "geohash", "image", "labelImage", "tfLite"}
 )