diff --git a/go.mod b/go.mod
index e5e90e9..2b4a191 100644
--- a/go.mod
+++ b/go.mod
@@ -17,6 +17,7 @@ require (
 	github.com/prometheus/client_golang v1.10.0
 	github.com/prometheus/common v0.24.0 // indirect
 	github.com/twmb/franz-go v0.9.0
+	github.com/twmb/franz-go/pkg/kmsg v0.0.0-20210726202344-c376dbc9081f
 	go.uber.org/atomic v1.7.0
 	go.uber.org/multierr v1.7.0 // indirect
 	go.uber.org/zap v1.16.0