我尝试在typescript项目中使用consumergroup而不是highlevelconsumer,但无法为consumergroup配置consumeroptions。
我在分配时遇到以下错误
1) fromoffset:'最早'
类型为{autocommit:boolean的参数;fetchmaxbytes:数字;fetchmaxwaitms:数字;fromoffset:字符串;groupid…'不可分配给“consumergroupoptions”类型的参数。属性“fromoffset”的类型不兼容。类型“string”不可分配给类型“earliest”|“latest”|“none”。
2) 协议:['roundrobin']
类型为{autocommit:boolean的参数;fetchmaxbytes:数字;fetchmaxwaitms:数字;协议:字符串[];groupid…'不可分配给“consumergroupoptions”类型的参数。属性“protocol”的类型不兼容。类型“string[]”不可分配给类型“(“roundrobin”|“range”| custompartitionassignmentprotocol)[]”。类型“string”不可分配给类型“roundrobin”|“range”| custompartitionassignmentprotocol”。
3) outofrangeoffset:'最早'
类型为{autocommit:boolean的参数;fetchmaxbytes:数字;fetchmaxwaitms:数字;outofrangeoffset:字符串;g、 ..不可分配给“consumergroupoptions”类型的参数。“outofrangeoffset”属性的类型不兼容。类型“string”不可分配给类型“earliest”|“latest”|“none”。
环境详情:
节点版本:v8.11.1
Kafka节点版本:v2.6.1
类型/Kafka节点:v2.0.6
有人能帮我理解我哪里出了问题吗?提前谢谢。
暂无答案!
目前还没有任何答案,快来回答吧!