diff --git a/pkg/batchmapper/examples/batchmap_flatmap/go.mod b/pkg/batchmapper/examples/batchmap_flatmap/go.mod
index cd04942a..bc0d6ca1 100644
--- a/pkg/batchmapper/examples/batchmap_flatmap/go.mod
+++ b/pkg/batchmapper/examples/batchmap_flatmap/go.mod
@@ -1,6 +1,8 @@
 module batchmap-flatmap
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/mapper/examples/even_odd/go.mod b/pkg/mapper/examples/even_odd/go.mod
index 85dc57e0..2236d748 100644
--- a/pkg/mapper/examples/even_odd/go.mod
+++ b/pkg/mapper/examples/even_odd/go.mod
@@ -1,6 +1,8 @@
 module even_odd
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/mapper/examples/flatmap/go.mod b/pkg/mapper/examples/flatmap/go.mod
index c8d1fdfa..72820028 100644
--- a/pkg/mapper/examples/flatmap/go.mod
+++ b/pkg/mapper/examples/flatmap/go.mod
@@ -1,6 +1,8 @@
 module flatmap
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/mapper/examples/forward_message/go.mod b/pkg/mapper/examples/forward_message/go.mod
index 89864ff3..7c1be428 100644
--- a/pkg/mapper/examples/forward_message/go.mod
+++ b/pkg/mapper/examples/forward_message/go.mod
@@ -1,6 +1,8 @@
 module forward_message
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/mapper/examples/retry/go.mod b/pkg/mapper/examples/retry/go.mod
index 4231789d..947381b9 100644
--- a/pkg/mapper/examples/retry/go.mod
+++ b/pkg/mapper/examples/retry/go.mod
@@ -1,6 +1,8 @@
 module retry
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/mapper/examples/slow_cat/go.mod b/pkg/mapper/examples/slow_cat/go.mod
index 85dc57e0..2236d748 100644
--- a/pkg/mapper/examples/slow_cat/go.mod
+++ b/pkg/mapper/examples/slow_cat/go.mod
@@ -1,6 +1,8 @@
 module even_odd
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/mapper/examples/tickgen/go.mod b/pkg/mapper/examples/tickgen/go.mod
index 320a014d..e215d655 100644
--- a/pkg/mapper/examples/tickgen/go.mod
+++ b/pkg/mapper/examples/tickgen/go.mod
@@ -1,6 +1,8 @@
 module tickgen
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/mapstreamer/examples/flatmap_stream/go.mod b/pkg/mapstreamer/examples/flatmap_stream/go.mod
index 1b070f10..321f9c30 100644
--- a/pkg/mapstreamer/examples/flatmap_stream/go.mod
+++ b/pkg/mapstreamer/examples/flatmap_stream/go.mod
@@ -1,6 +1,8 @@
 module flatmap_stream
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/reducer/examples/counter/go.mod b/pkg/reducer/examples/counter/go.mod
index fbe62e08..2ec30d42 100644
--- a/pkg/reducer/examples/counter/go.mod
+++ b/pkg/reducer/examples/counter/go.mod
@@ -1,6 +1,8 @@
 module counter
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/reducer/examples/sum/go.mod b/pkg/reducer/examples/sum/go.mod
index 71ade673..32fbca64 100644
--- a/pkg/reducer/examples/sum/go.mod
+++ b/pkg/reducer/examples/sum/go.mod
@@ -1,6 +1,8 @@
 module sum
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/reducestreamer/examples/counter/go.mod b/pkg/reducestreamer/examples/counter/go.mod
index fbe62e08..2ec30d42 100644
--- a/pkg/reducestreamer/examples/counter/go.mod
+++ b/pkg/reducestreamer/examples/counter/go.mod
@@ -1,6 +1,8 @@
 module counter
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/reducestreamer/examples/sum/go.mod b/pkg/reducestreamer/examples/sum/go.mod
index 71ade673..32fbca64 100644
--- a/pkg/reducestreamer/examples/sum/go.mod
+++ b/pkg/reducestreamer/examples/sum/go.mod
@@ -1,6 +1,8 @@
 module sum
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sessionreducer/examples/counter/go.mod b/pkg/sessionreducer/examples/counter/go.mod
index 29556dfe..d4ad741c 100644
--- a/pkg/sessionreducer/examples/counter/go.mod
+++ b/pkg/sessionreducer/examples/counter/go.mod
@@ -1,6 +1,8 @@
 module counter
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sessionreducer/examples/sum/go.mod b/pkg/sessionreducer/examples/sum/go.mod
index f57b6f8c..25fa6310 100644
--- a/pkg/sessionreducer/examples/sum/go.mod
+++ b/pkg/sessionreducer/examples/sum/go.mod
@@ -1,6 +1,8 @@
 module sum
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sideinput/examples/map_sideinput/go.mod b/pkg/sideinput/examples/map_sideinput/go.mod
index 7a8f5b92..5599295a 100644
--- a/pkg/sideinput/examples/map_sideinput/go.mod
+++ b/pkg/sideinput/examples/map_sideinput/go.mod
@@ -1,6 +1,8 @@
 module map_sideinput
 
-go 1.21.2
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sideinput/examples/map_sideinput/udf/go.mod b/pkg/sideinput/examples/map_sideinput/udf/go.mod
index f19c7c5d..c1c93a11 100644
--- a/pkg/sideinput/examples/map_sideinput/udf/go.mod
+++ b/pkg/sideinput/examples/map_sideinput/udf/go.mod
@@ -1,6 +1,8 @@
 module udf
 
-go 1.21.2
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../../..
 
diff --git a/pkg/sideinput/examples/reduce_sideinput/go.mod b/pkg/sideinput/examples/reduce_sideinput/go.mod
index f45d0e0f..2753df71 100644
--- a/pkg/sideinput/examples/reduce_sideinput/go.mod
+++ b/pkg/sideinput/examples/reduce_sideinput/go.mod
@@ -1,6 +1,8 @@
 module reduce_sideinput
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sideinput/examples/reduce_sideinput/udf/go.mod b/pkg/sideinput/examples/reduce_sideinput/udf/go.mod
index 507b2beb..81f7a1b4 100644
--- a/pkg/sideinput/examples/reduce_sideinput/udf/go.mod
+++ b/pkg/sideinput/examples/reduce_sideinput/udf/go.mod
@@ -1,6 +1,8 @@
 module udf
 
-go 1.21.2
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../../..
 
diff --git a/pkg/sideinput/examples/sideinput_function/go.mod b/pkg/sideinput/examples/sideinput_function/go.mod
index d5d4c8cd..36998957 100644
--- a/pkg/sideinput/examples/sideinput_function/go.mod
+++ b/pkg/sideinput/examples/sideinput_function/go.mod
@@ -1,6 +1,8 @@
 module even_odd_sideinput
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sideinput/examples/simple_sideinput/go.mod b/pkg/sideinput/examples/simple_sideinput/go.mod
index 9b330d6b..1ea6b1ac 100644
--- a/pkg/sideinput/examples/simple_sideinput/go.mod
+++ b/pkg/sideinput/examples/simple_sideinput/go.mod
@@ -1,6 +1,8 @@
 module simple_sideinput
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sideinput/examples/simple_sideinput/udf/go.mod b/pkg/sideinput/examples/simple_sideinput/udf/go.mod
index 18725d1c..c1c93a11 100644
--- a/pkg/sideinput/examples/simple_sideinput/udf/go.mod
+++ b/pkg/sideinput/examples/simple_sideinput/udf/go.mod
@@ -1,6 +1,8 @@
 module udf
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../../..
 
diff --git a/pkg/sideinput/examples/simple_source_with_sideinput/go.mod b/pkg/sideinput/examples/simple_source_with_sideinput/go.mod
index da5107e8..ffb8da09 100644
--- a/pkg/sideinput/examples/simple_source_with_sideinput/go.mod
+++ b/pkg/sideinput/examples/simple_source_with_sideinput/go.mod
@@ -1,6 +1,8 @@
 module simple_source_with_sideinput
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sideinput/examples/sink_sideinput/go.mod b/pkg/sideinput/examples/sink_sideinput/go.mod
index 735a05a6..86b2d865 100644
--- a/pkg/sideinput/examples/sink_sideinput/go.mod
+++ b/pkg/sideinput/examples/sink_sideinput/go.mod
@@ -1,6 +1,8 @@
 module sink_sideinput
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sinker/examples/fallback/go.mod b/pkg/sinker/examples/fallback/go.mod
index 1cd7e07b..1d3af009 100644
--- a/pkg/sinker/examples/fallback/go.mod
+++ b/pkg/sinker/examples/fallback/go.mod
@@ -1,6 +1,8 @@
 module fallback
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sinker/examples/log/go.mod b/pkg/sinker/examples/log/go.mod
index ac86c784..ec328abd 100644
--- a/pkg/sinker/examples/log/go.mod
+++ b/pkg/sinker/examples/log/go.mod
@@ -1,6 +1,8 @@
 module log_sink
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sinker/examples/redis_sink/go.mod b/pkg/sinker/examples/redis_sink/go.mod
index 98192b69..56d68ea3 100644
--- a/pkg/sinker/examples/redis_sink/go.mod
+++ b/pkg/sinker/examples/redis_sink/go.mod
@@ -1,6 +1,8 @@
 module redis-e2e-test-sink
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sourcer/examples/simple_source/go.mod b/pkg/sourcer/examples/simple_source/go.mod
index 2a8b4f7f..eadefc27 100644
--- a/pkg/sourcer/examples/simple_source/go.mod
+++ b/pkg/sourcer/examples/simple_source/go.mod
@@ -1,6 +1,8 @@
 module simple_source
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sourcetransformer/examples/assign_event_time/go.mod b/pkg/sourcetransformer/examples/assign_event_time/go.mod
index 54232c8a..e3f93c83 100644
--- a/pkg/sourcetransformer/examples/assign_event_time/go.mod
+++ b/pkg/sourcetransformer/examples/assign_event_time/go.mod
@@ -1,6 +1,8 @@
 module assign_event_time
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..
 
diff --git a/pkg/sourcetransformer/examples/event_time_filter/go.mod b/pkg/sourcetransformer/examples/event_time_filter/go.mod
index b7ca4732..e96a9053 100644
--- a/pkg/sourcetransformer/examples/event_time_filter/go.mod
+++ b/pkg/sourcetransformer/examples/event_time_filter/go.mod
@@ -1,6 +1,8 @@
 module event_time_filter
 
-go 1.21
+go 1.22
+
+toolchain go1.23.1
 
 replace github.com/numaproj/numaflow-go => ../../../..