diff --git a/go.mod b/go.mod
index 27a7560..0702ab6 100644
--- a/go.mod
+++ b/go.mod
@@ -4,6 +4,6 @@ go 1.15
 
 require (
 	github.com/google/uuid v1.2.0
-	github.com/segmentio/kafka-go v0.4.15
+	github.com/segmentio/kafka-go v0.4.16
 	github.com/unistack-org/micro/v3 v3.3.17
 )
diff --git a/go.sum b/go.sum
index d1c6411..6b24310 100644
--- a/go.sum
+++ b/go.sum
@@ -31,6 +31,8 @@ github.com/segmentio/kafka-go v0.4.14 h1:b/Zp/H4fz6ME4vDhEy/90qVJj20Hkh41NYZpIu+
 github.com/segmentio/kafka-go v0.4.14/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
 github.com/segmentio/kafka-go v0.4.15 h1:cEcaQX2cTenDH3LIMFfIQNzGxYWGNMp0LdWmYv89h64=
 github.com/segmentio/kafka-go v0.4.15/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
+github.com/segmentio/kafka-go v0.4.16 h1:9dt78ehM9qzAkekA60D6A96RlqDzC3hnYYa8y5Szd+U=
+github.com/segmentio/kafka-go v0.4.16/go.mod h1:19+Eg7KwrNKy/PFhiIthEPkO8k+ac7/ZYXwYM9Df10w=
 github.com/silas/dag v0.0.0-20210121180416-41cf55125c34/go.mod h1:7RTUFBdIRC9nZ7/3RyRNH1bdqIShrDejd1YbLwgPS+I=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.6.1 h1:hDPOHmpOpP40lSULcqw7IrRb/u7w6RpDC9399XyoNd0=