diff --git a/driver/kafka/go.mod b/driver/kafka/go.mod
index 9ac1b87..a1e0ffb 100644
--- a/driver/kafka/go.mod
+++ b/driver/kafka/go.mod
@@ -5,12 +5,13 @@ go 1.18
 replace github.com/alexandria-oss/streams => ../../
 
 require (
-	github.com/alexandria-oss/streams v0.0.0-00010101000000-000000000000
+	github.com/alexandria-oss/streams v0.0.1-alpha.7
 	github.com/segmentio/kafka-go v0.4.39
 	github.com/stretchr/testify v1.8.2
 )
 
 require (
+	github.com/allegro/bigcache/v3 v3.1.0 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/eapache/go-resiliency v1.3.0 // indirect
 	github.com/google/uuid v1.3.0 // indirect
diff --git a/driver/kafka/go.sum b/driver/kafka/go.sum
index cc5d6ab..e491939 100644
--- a/driver/kafka/go.sum
+++ b/driver/kafka/go.sum
@@ -1,3 +1,5 @@
+github.com/allegro/bigcache/v3 v3.1.0 h1:H2Vp8VOvxcrB91o86fUSVJFqeuz8kpyyB02eH3bSzwk=
+github.com/allegro/bigcache/v3 v3.1.0/go.mod h1:aPyh7jEvrog9zAwx5N7+JUQX5dZTSGpxF1LAR4dr35I=
 github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
diff --git a/driver/sql/go.mod b/driver/sql/go.mod
index f98b648..1a3fcc3 100644
--- a/driver/sql/go.mod
+++ b/driver/sql/go.mod
@@ -6,12 +6,13 @@ replace github.com/alexandria-oss/streams => ../../
 
 require (
 	github.com/DATA-DOG/go-sqlmock v1.5.0
-	github.com/alexandria-oss/streams v0.0.1-alpha.5
+	github.com/alexandria-oss/streams v0.0.1-alpha.7
 	github.com/lib/pq v1.10.7
 	github.com/stretchr/testify v1.8.2
 )
 
 require (
+	github.com/allegro/bigcache/v3 v3.1.0 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/eapache/go-resiliency v1.3.0 // indirect
 	github.com/google/uuid v1.3.0 // indirect
diff --git a/driver/sql/go.sum b/driver/sql/go.sum
index 598c6e4..e32ebf3 100644
--- a/driver/sql/go.sum
+++ b/driver/sql/go.sum
@@ -1,5 +1,7 @@
 github.com/DATA-DOG/go-sqlmock v1.5.0 h1:Shsta01QNfFxHCfpW6YH2STWB0MudeXXEWMr20OEh60=
 github.com/DATA-DOG/go-sqlmock v1.5.0/go.mod h1:f/Ixk793poVmq4qj/V1dPUg2JEAKC73Q5eFN3EC/SaM=
+github.com/allegro/bigcache/v3 v3.1.0 h1:H2Vp8VOvxcrB91o86fUSVJFqeuz8kpyyB02eH3bSzwk=
+github.com/allegro/bigcache/v3 v3.1.0/go.mod h1:aPyh7jEvrog9zAwx5N7+JUQX5dZTSGpxF1LAR4dr35I=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=