diff --git a/go.mod b/go.mod
index e18dd14..04053fc 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.20201009214709-0e1f744fcc43
+	github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20201012090909-6e43ae719076
 	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 77ae5e6..1d0ee30 100644
--- a/go.sum
+++ b/go.sum
@@ -306,8 +306,8 @@ github.com/unistack-org/micro-config-cmd v0.0.0-20200920140133-0853deb2e5dc/go.m
 github.com/unistack-org/micro/v3 v3.0.0-20200827083227-aa99378adc6e/go.mod h1:rPQbnry3nboAnMczj8B1Gzlcyv/HYoMZLgd3/3nttJ4=
 github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20200909210629-caec730248b1/go.mod h1:mmqHR9WelHUXqg2mELjsQ+FJHcWs6mNmXg+wEYO2T3c=
 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.20201009214709-0e1f744fcc43 h1:OX0dKb5zyehQbYztStWsLuLlW7IWICAr1nRI2Da3aWs=
-github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20201009214709-0e1f744fcc43/go.mod h1:aL+8VhSXpx0SuEeXPOWUo5BgS7kyvWYobeXFay90UUM=
+github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20201012090909-6e43ae719076 h1:gnF5cIE+vYCpmEfVzu/tTC/Gsh8U47sjhYLS49Z4p1I=
+github.com/unistack-org/micro/v3 v3.0.0-gamma.0.20201012090909-6e43ae719076/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 b7567a9..a2c5626 100644
--- a/options.go
+++ b/options.go
@@ -5,6 +5,7 @@ import (
 
 	kafka "github.com/segmentio/kafka-go"
 	"github.com/unistack-org/micro/v3/broker"
+	"github.com/unistack-org/micro/v3/client"
 )
 
 var (
@@ -47,3 +48,7 @@ type publishKey struct{}
 func PublishKey(key []byte) broker.PublishOption {
 	return broker.SetPublishOption(publishKey{}, key)
 }
+
+func ClientPublishKey(key []byte) client.PublishOption {
+	return client.SetPublishOption(publishKey{}, key)
+}