diff --git a/consumer/pull_consumer.go b/consumer/pull_consumer.go index a53d0b86..ad91d4ee 100644 --- a/consumer/pull_consumer.go +++ b/consumer/pull_consumer.go @@ -537,7 +537,7 @@ func (pc *defaultPullConsumer) GetWhere() string { case ConsumeFromTimestamp: return "CONSUME_FROM_TIMESTAMP" default: - return "UNKOWN" + return "UNKNOWN" } } diff --git a/consumer/push_consumer.go b/consumer/push_consumer.go index 5f00bac1..a243a2f5 100644 --- a/consumer/push_consumer.go +++ b/consumer/push_consumer.go @@ -349,7 +349,7 @@ func (pc *pushConsumer) GetWhere() string { case ConsumeFromTimestamp: return "CONSUME_FROM_TIMESTAMP" default: - return "UNKOWN" + return "UNKNOWN" } } diff --git a/internal/client.go b/internal/client.go index 811aa64a..408e942c 100644 --- a/internal/client.go +++ b/internal/client.go @@ -606,7 +606,7 @@ func (c *rmqClient) SendHeartbeatToAllBrokerWithLock() { }) if hbData.ProducerDatas.Len() == 0 && hbData.ConsumerDatas.Len() == 0 { rlog.Info("sending heartbeat, but no producer and no consumer", map[string]interface{}{ - "clientid": hbData.ClientId, + "clientId": hbData.ClientId, }) return }