From ba1adb9e31b8a02f7263ed1652574747cd337942 Mon Sep 17 00:00:00 2001 From: leonyue Date: Fri, 6 Dec 2024 11:18:44 +0800 Subject: [PATCH] adjust comment --- .../tubemq-client-go/client/consumer_impl.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go b/inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go index b06295ab42f..c78f2469b5d 100644 --- a/inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go +++ b/inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go @@ -132,7 +132,7 @@ func (c *consumer) routine(ctx context.Context) { return default: } - // 选主 + // select master node, err := c.selector.Select(c.config.Consumer.Masters) if err != nil { log.Errorf("[CONSUMER] select error %v", err) @@ -141,14 +141,14 @@ func (c *consumer) routine(ctx context.Context) { } c.master = node log.Infof("[CONSUMER] master %+v", c.master) - // 注册 + // register to master if err := c.register2Master(ctx); err != nil { log.Errorf("[CONSUMER] register2Master error %v", err) time.Sleep(time.Second) continue } c.lastMasterHb = time.Now().UnixMilli() - // 心跳 + // heartbeat to master time.Sleep(c.config.Heartbeat.Interval / 2) if err := c.heartbeat2Master(ctx); err != nil { log.Errorf("[CONSUMER] heartbeat2Master error %v", err)