这个 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文件-