I'm using golang rocketmq-client as producer to send message.
https://github.com/apache/rocketmq-client-go
I tried to send message with SendSync() function.
If message size less than 128k, it works fine.
// golang code
msg := &primitive.Message{
Topic: Cfg.Topic,
Body: []byte(message),
}
res, err := Producer.SendSync(context.Background(), msg)
if err != nil {
return err
}
If the message size exceeds 128k, I got an error:
the message is illegal, maybe msg body or properties length not matched. msg body length limit 128k, msg properties length limit 32k.
Printing broker config with following command:
...
maxMessageSize=4194304
...
What's the problem please?