我正在将一个应用程序从kafka0.7转换为kafka0.8，并且我必须为一个简单的使用者使用新的api。在这样做的过程中，我跟随这里的示例，并从我们当前的实现转换为api。但是，在创建offsetrequest对象时，示例会传递一个字符串作为第三个参数，我从ApacheKafka中提取的jar需要一个名为“replicaid”的字符串类型的arg，我找不到任何关于这个值是什么的文档，有人能解释一下它是什么，如果有默认值，就像其他类似的Kafkaapi的，我会很感激知道他们是什么。
谢谢您！
我正在将一个应用程序从kafka0.7转换为kafka0.8，并且我必须为一个简单的使用者使用新的api。在这样做的过程中，我跟随这里的示例，并从我们当前的实现转换为api。但是，在创建offsetrequest对象时，示例会传递一个字符串作为第三个参数，我从ApacheKafka中提取的jar需要一个名为“replicaid”的字符串类型的arg，我找不到任何关于这个值是什么的文档，有人能解释一下它是什么，如果有默认值，就像其他类似的Kafkaapi的，我会很感激知道他们是什么。
谢谢您！
1条答案
按热度按时间s8vozzvw1#
你拉的不是jar——你使用的是某种内部api(
kafka.api.OffsetRequest)，而不是示例中所示的(kafka.javaapi.OffsetRequest).如果你还想用前一个，设置
replicaid默认值：kafka.api.Request.OrdinaryConsumerId（实际上是-1），但我建议你回到kafka.javaapi.OffsetRequest.