diff --git a/internal/topic/topiclistenerinternal/topic_listener_reconnector.go b/internal/topic/topiclistenerinternal/topic_listener_reconnector.go index 995403a1f..9a9afc5d5 100644 --- a/internal/topic/topiclistenerinternal/topic_listener_reconnector.go +++ b/internal/topic/topiclistenerinternal/topic_listener_reconnector.go @@ -64,7 +64,6 @@ func (lr *TopicListenerReconnector) Close(ctx context.Context, reason error) err } func (lr *TopicListenerReconnector) connect(connectionCtx context.Context) { - sl, connRes := newStreamListener( connectionCtx, lr.client,