1

我正在尝试在打字稿项目中使用 consumerGroup 而不是 HighLevelConsumer，但我无法为 consumerGroup 配置 consumerOptions。

分配时出现以下错误

1) fromOffset: '最早的'

'{ autoCommit: boolean; 类型的参数 fetchMaxBytes：数字；fetchMaxWaitMs：数字；从偏移：字符串；groupId...' 不可分配给“ConsumerGroupOptions”类型的参数。属性“fromOffset”的类型不兼容。类型 'string' 不可分配给类型 '"earliest" | “最新” | “没有任何”'。

2）协议：['roundrobin']

'{ autoCommit: boolean; 类型的参数 fetchMaxBytes：数字；fetchMaxWaitMs：数字；协议：字符串[]；groupId...' 不可分配给“ConsumerGroupOptions”类型的参数。属性“协议”的类型不兼容。类型 'string[]' 不能分配给类型 '("roundrobin" | "range" | CustomPartitionAssignmentProtocol)[]'。类型 'string' 不可分配给类型 '"roundrobin" | “范围” | CustomPartitionAssignmentProtocol'。

3) outOfRangeOffset: '最早的'

'{ autoCommit: boolean; 类型的参数 fetchMaxBytes：数字；fetchMaxWaitMs：数字；outOfRangeOffset：字符串；g...' 不可分配给“ConsumerGroupOptions”类型的参数。属性“outOfRangeOffset”的类型不兼容。类型 'string' 不可分配给类型 '"earliest" | “最新” | “没有任何”'。

环境细节：

  • 节点版本：v8.11.1
  • 卡夫卡节点版本：v2.6.1
  • 类型/kafka 节点：v2.0.6

谁能帮我理解我哪里出错了？提前致谢。

4

0 回答 0