Skip to content

Commit 8f75f4b

Browse files
authored
[ISSEU #683]request parameter type error fix
Signed-off-by: zhangyang <Git_Yang@163.com>
1 parent 3daa659 commit 8f75f4b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

internal/request.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ type SendMessageRequestHeader struct {
6666
MaxReconsumeTimes int
6767
Batch bool
6868
DefaultTopic string
69-
DefaultTopicQueueNums string
69+
DefaultTopicQueueNums int
7070
}
7171

7272
func (request *SendMessageRequestHeader) Encode() map[string]string {
@@ -107,7 +107,7 @@ func (request *SendMessageRequestV2Header) Encode() map[string]string {
107107
maps["a"] = request.ProducerGroup
108108
maps["b"] = request.Topic
109109
maps["c"] = request.DefaultTopic
110-
maps["d"] = request.DefaultTopicQueueNums
110+
maps["d"] = strconv.Itoa(request.DefaultTopicQueueNums)
111111
maps["e"] = strconv.Itoa(request.QueueId)
112112
maps["f"] = fmt.Sprintf("%d", request.SysFlag)
113113
maps["g"] = strconv.FormatInt(request.BornTimestamp, 10)

0 commit comments

Comments
 (0)