本文介绍使用 RocketMQ Go 客户端 SDK,访问火山引擎消息队列 RocketMQ版来收发消息的流程。
RocketMQ Go SDK 支持连接火山引擎消息队列 RocketMQ版,请使用指定 Commit 及后续版本的社区版 Go SDK,指定版本的下载地址请参考 Go SDK 下载地址。
说明
Q:为什么要使用指定 Commit 及后续的版本?
A:指定 Commit(83f60c154236bb92a5d5e3d40276b546b6079f1b)及后续版本修复了在线重置 consumer offset 的功能缺陷。若使用此 commit 号之前的版本,可能会引起报错或业务异常。
请按顺序执行以下操作。
说明
详细信息请参考准备工作。
在使用 Go SDK 接入火山引擎消息队列 RocketMQ版收发消息时,需要配置相应的参数。更多信息请参考参数说明。
您也可以查看示例代码中的注释,了解各个关键参数用法。