[ISSEU #683]request parameter type error fix
Signed-off-by: zhangyang <Git_Yang@163.com>
diff --git a/internal/request.go b/internal/request.go
index ed3de33..237d711 100644
--- a/internal/request.go
+++ b/internal/request.go
@@ -66,7 +66,7 @@
MaxReconsumeTimes int
Batch bool
DefaultTopic string
- DefaultTopicQueueNums string
+ DefaultTopicQueueNums int
}
func (request *SendMessageRequestHeader) Encode() map[string]string {
@@ -107,7 +107,7 @@
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)
