bulker topic_manager: support bulker sharding

jitsucom · Mar 5, 2024 · 57b10db · 57b10db
1 parent 4269bce
commit 57b10db
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/bulkerapp/app/topic_manager.go b/bulkerapp/app/topic_manager.go
@@ -113,6 +113,7 @@ func NewTopicManager(appContext *Context) (*TopicManager, error) {
 
 // Start starts TopicManager
 func (tm *TopicManager) Start() {
+	tm.Infof("Starting topic manager. Shard Number: %d", tm.shardNumber)
 	tm.LoadMetadata()
 	safego.RunWithRestart(func() {
 		ticker := time.NewTicker(time.Duration(tm.config.TopicManagerRefreshPeriodSec) * time.Second)