Improve logging

zoonru · Sep 26, 2023 · 884413d · 884413d
1 parent 81f6d44
commit 884413d
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/consumer/groupcsm/groupcsm.go b/consumer/groupcsm/groupcsm.go
@@ -163,6 +163,8 @@ func (gc *T) run() {
 				}
 				nilOrRetryCh = time.After(gc.cfg.Consumer.RetryBackoff)
 				rebalanceScheduled = true
+			} else {
+				gc.actDesc.Log().Info("rebalancing done")
 			}
 			if stopped {
 				goto done

diff --git a/consumer/subscriber/subscriber.go b/consumer/subscriber/subscriber.go
@@ -132,6 +132,7 @@ func (s *T) run() {
 		select {
 		case topics = <-s.topicsCh:
 			sort.Strings(topics)
+			s.actDesc.Log().Infof("Resubmit triggered by new topics=%v", topics)
 			shouldSubmitTopics = true
 
 		case nilOrSubscriptionsCh <- subscriptions: