Hil*_*ild 6 real-time-data apache-kafka
消息被消费或处理后,如何从Kafka获得确认.可能听起来很愚蠢,但有没有办法知道收到确认的消息的开始和结束偏移量？
到目前为止我发现在 0.8 中他们引入了以下方法来选择读取的偏移量..
kafka.api.OffsetRequest.EarliestTime() 找到日志中数据的开头并从那里开始流式传输，kafka.api.OffsetRequest.LatestTime() 将仅流式传输新消息。
示例代码 https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example
仍然不确定致谢部分
| 归档时间： |
|
| 查看次数： |
6285 次 |
| 最近记录： |