From 0795ba37c3f4940caf4b7d0864ab0d6dc90bdb50 Mon Sep 17 00:00:00 2001
From: Vasiliy Tolstov <v.tolstov@unistack.org>
Date: Wed, 10 Feb 2021 00:19:08 +0300
Subject: [PATCH] fix broker implementation

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
---
 segmentio.go | 4 ++++
 1 file changed, 4 insertions(+)

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 {