From fa718621e3b1ce865374d82a75eb071eac5f94ef Mon Sep 17 00:00:00 2001 From: zhangyang Date: Thu, 17 Jun 2021 19:48:37 +0800 Subject: [PATCH] request parameter type error fix Signed-off-by: zhangyang --- internal/request.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/request.go b/internal/request.go index ed3de33b..237d7118 100644 --- a/internal/request.go +++ b/internal/request.go @@ -66,7 +66,7 @@ type SendMessageRequestHeader struct { MaxReconsumeTimes int Batch bool DefaultTopic string - DefaultTopicQueueNums string + DefaultTopicQueueNums int } func (request *SendMessageRequestHeader) Encode() map[string]string { @@ -107,7 +107,7 @@ func (request *SendMessageRequestV2Header) Encode() map[string]string { maps["a"] = request.ProducerGroup maps["b"] = request.Topic maps["c"] = request.DefaultTopic - maps["d"] = request.DefaultTopicQueueNums + maps["d"] = strconv.Itoa(request.DefaultTopicQueueNums) maps["e"] = strconv.Itoa(request.QueueId) maps["f"] = fmt.Sprintf("%d", request.SysFlag) maps["g"] = strconv.FormatInt(request.BornTimestamp, 10)