diff --git a/pg_stream/go.mod b/pg_stream/go.mod
index 892c919..0477636 100644
--- a/pg_stream/go.mod
+++ b/pg_stream/go.mod
@@ -5,7 +5,6 @@ go 1.22
 toolchain go1.22.1
 
 require (
-	github.com/charmbracelet/log v0.3.0
 	github.com/jackc/pgx/v5 v5.5.4
 	github.com/jaswdr/faker v1.19.1
 	github.com/lib/pq v1.10.9
@@ -30,6 +29,7 @@ require (
 	github.com/aymanbagabas/go-osc52/v2 v2.0.1 // indirect
 	github.com/cenkalti/backoff/v4 v4.3.0 // indirect
 	github.com/charmbracelet/lipgloss v0.9.1 // indirect
+	github.com/charmbracelet/log v0.3.0 // indirect
 	github.com/cockroachdb/apd/v3 v3.2.1 // indirect
 	github.com/containerd/continuity v0.4.3 // indirect
 	github.com/cpuguy83/go-md2man/v2 v2.0.4 // indirect
diff --git a/pg_stream/go.sum b/pg_stream/go.sum
index 2b5d62c..56009f1 100644
--- a/pg_stream/go.sum
+++ b/pg_stream/go.sum
@@ -228,6 +228,8 @@ github.com/trivago/tgo v1.0.7 h1:uaWH/XIy9aWYWpjm2CU3RpcqZXmX2ysQ9/Go+d9gyrM=
 github.com/trivago/tgo v1.0.7/go.mod h1:w4dpD+3tzNIIiIfkWWa85w5/B77tlvdZckQ+6PkFnhc=
 github.com/urfave/cli/v2 v2.27.4 h1:o1owoI+02Eb+K107p27wEX9Bb8eqIoZCfLXloLUSWJ8=
 github.com/urfave/cli/v2 v2.27.4/go.mod h1:m4QzxcD2qpra4z7WhzEGn74WZLViBnMpb1ToCAKdGRQ=
+github.com/usedatabrew/pglogicalstream v0.0.6-benthos-rs h1:k3zem5N0ZdNK+El3wUI1Zk81hCoOzPt+y7fSqFJ+FAU=
+github.com/usedatabrew/pglogicalstream v0.0.6-benthos-rs/go.mod h1:nb7BtgDevdmH50IMdGgCj3OrO5iQCq00pgvLiMTSELg=
 github.com/xeipuuv/gojsonpointer v0.0.0-20180127040702-4e3ac2762d5f/go.mod h1:N2zxlSyiKSe5eX1tZViRH5QA0qijqEDrYZiPEAiq3wU=
 github.com/xeipuuv/gojsonpointer v0.0.0-20190905194746-02993c407bfb h1:zGWFAtiMcyryUHoUjUJX0/lt1H2+i2Ka2n+D3DImSNo=
 github.com/xeipuuv/gojsonpointer v0.0.0-20190905194746-02993c407bfb/go.mod h1:N2zxlSyiKSe5eX1tZViRH5QA0qijqEDrYZiPEAiq3wU=