diff --git a/go.mod b/go.mod
index 62c21b6..2bd8aca 100644
--- a/go.mod
+++ b/go.mod
@@ -7,7 +7,7 @@ require (
 	github.com/google/uuid v1.1.2
 	github.com/segmentio/kafka-go v0.3.8
 	github.com/stretchr/testify v1.6.1 // indirect
-	github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20200922101505-ec3c1a02fce6
+	github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20200922101738-21d5ca1cddc1
 	golang.org/x/text v0.3.3 // indirect
 	golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 // indirect
 )
diff --git a/go.sum b/go.sum
index 67701b2..f973c79 100644
--- a/go.sum
+++ b/go.sum
@@ -308,6 +308,8 @@ github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20200909210629-caec730248b1/go.m
 github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20200920135754-1cbd1d2bad83/go.mod h1:HUzMG4Mcy97958VxWTg8zuazZgwQ/aoLZ8wtBVONwRE=
 github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20200922101505-ec3c1a02fce6 h1:gDXQgBibadqZFbV+JZXxu3J2dK2kVJYmRuy/5Jh/xd8=
 github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20200922101505-ec3c1a02fce6/go.mod h1:aL+8VhSXpx0SuEeXPOWUo5BgS7kyvWYobeXFay90UUM=
+github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20200922101738-21d5ca1cddc1 h1:Ki+acK9YEn6OuqOQkZZPrGEslmeMvS9kPSObU01yn2E=
+github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20200922101738-21d5ca1cddc1/go.mod h1:aL+8VhSXpx0SuEeXPOWUo5BgS7kyvWYobeXFay90UUM=
 github.com/urfave/cli v1.22.1/go.mod h1:Gos4lmkARVdJ6EkW0WaNv/tZAAMe9V7XWyB60NtXRu0=
 github.com/vultr/govultr v0.1.4/go.mod h1:9H008Uxr/C4vFNGLqKx232C206GL0PBHzOP0809bGNA=
 github.com/xdg/scram v0.0.0-20180814205039-7eeb5667e42c h1:u40Z8hqBAAQyv+vATcGgV0YCnDjqSL7/q/JyPhhJSPk=
diff --git a/options.go b/options.go
index 4759223..ce20a99 100644
--- a/options.go
+++ b/options.go
@@ -16,11 +16,11 @@ type readerConfigKey struct{}
 type writerConfigKey struct{}
 
 func ReaderConfig(c kafka.ReaderConfig) broker.Option {
-	return broker.SetBrokerOption(readerConfigKey{}, c)
+	return broker.SetOption(readerConfigKey{}, c)
 }
 
 func WriterConfig(c kafka.WriterConfig) broker.Option {
-	return broker.SetBrokerOption(writerConfigKey{}, c)
+	return broker.SetOption(writerConfigKey{}, c)
 }
 
 type subscribeContextKey struct{}