diff --git a/segmentio.go b/segmentio.go
index 883bdf1..f7a9d36 100644
--- a/segmentio.go
+++ b/segmentio.go
@@ -100,6 +100,10 @@ func (k *kBroker) Address() string {
 	return "127.0.0.1:9092"
 }
 
+func (k *kBroker) Name() string {
+	return k.opts.Name
+}
+
 func (k *kBroker) Connect(ctx context.Context) error {
 	k.RLock()
 	if k.connected {