这个 OffsetRequest 已经被弃用了一段时间，几乎所有的其他类 kafka.api 现在已在1.0中删除。但是，无论是deprecation消息还是docs都没有解释什么可以替代。常见问题解答对此主题没有帮助。有cli工具可以做到这一点，但是我还没有找到任何关于以编程方式实现的建议。
OffsetRequest
kafka.api
g9icjywg1#
中的类 kafka.api 用于旧客户机（在scala中），这些客户机已被弃用，并将在将来的版本中删除。新的java客户机正在使用中定义的类 org.apache.kafka.common.requests .班级 org.apache.kafka.common.requests.ListOffsetRequest 是旧的替代品吗 OffsetRequest .以下方法来自 KafkaConsumer 可用于检索偏移量（它们都发送 ListOffsetRequest 来自客户）：开始偏移（）：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#beginningoffsets-java.util.collection集合-内偏移（）：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#endoffsets-java.util.collection集合-偏移时间（）：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#offsetsfortimes-java.util.map文件-
org.apache.kafka.common.requests
org.apache.kafka.common.requests.ListOffsetRequest
KafkaConsumer
ListOffsetRequest
1条答案
按热度按时间g9icjywg1#
中的类
kafka.api用于旧客户机（在scala中），这些客户机已被弃用，并将在将来的版本中删除。新的java客户机正在使用中定义的类
org.apache.kafka.common.requests.班级
org.apache.kafka.common.requests.ListOffsetRequest是旧的替代品吗OffsetRequest.以下方法来自
KafkaConsumer可用于检索偏移量（它们都发送ListOffsetRequest来自客户）：开始偏移（）：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#beginningoffsets-java.util.collection集合-
内偏移（）：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#endoffsets-java.util.collection集合-
偏移时间（）：http://kafka.apache.org/10/javadoc/org/apache/kafka/clients/consumer/kafkaconsumer.html#offsetsfortimes-java.util.map文件-