0
我使用Logstash從Kafka主題獲取數據並將其插入Elasticsearch。由於Logstash中存在一些配置錯誤，我得到了損壞的數據，並且我想重新使用昨天2 O時鐘的主題。這可能嗎？如何將卡夫卡消費羣體的偏移重置/回滾到特定小時？
A
回答
0
目前，kafka Logstash input不支持在Kafka 0.10中引入的按時間戳搜索功能。
Suyog拉奧（Logstash小組組長）一直working on a feature branch添加此功能，但我最後一次檢查它沒有工作，因爲comment mentioned on lines 292-294，即
這是沒有不工作分區分配尚未:( 見https://issues.apache.org/jira/browse/KAFKA-2359 我們需要調用的poll（），然後再尋找這沒有任何意義，並可能會丟失數據
相關問題
- 1. 如何重置卡夫卡的消費羣體？
- 2. 重置卡夫卡消費者的上一次偏移量
- 3. 卡夫卡0.9：消費從最早的卡夫卡偏移
- 4. 卡夫卡消費羣體和分區
- 5. 卡夫卡 - 同步消費羣體
- 6. 卡夫卡消費羣掛
- 7. 從卡夫卡流重置消費者偏移量
- 8. 如何確定卡夫卡消費者的偏移
- 9. 如何重置用於消費卡夫卡消息的偏移量？
- 10. 卡夫卡的NodeJS與消費羣PM2
- 11. 卡夫卡消費者中的控制消息偏移量
- 12. 如何創建卡夫卡消費者羣體？
- 13. 卡夫卡0.9新消費者api ---如何看消費者偏移
- 14. 卡夫卡消費羣過期了嗎？
- 15. 卡夫卡：多個實例中的單一消費羣體
- 16. 卡夫卡0.11如何重置偏移量
- 17. 卡夫卡消費者不消費
- 18. 卡夫卡gruop消費者
- 19. 卡夫卡消費10節
- 20. 如何暫停卡夫卡消費者？
- 21. 卡夫卡消費者卡住加入集羣
- 22. 如何從生產者消費卡夫卡的消費者？
- 23. Flink - 查詢卡夫卡主題用於消費羣體的抵消？
- 24. 卡夫卡到Elasticsearch消費與node.js
- 25. 在卡夫卡消費活的消息
- 26. 如何使卡夫卡消費者從上次消費的偏移量讀取，但不是從開始
- 27. 多個消費羣體消費者如何在卡夫卡的同一主題上跨越分區工作？
- 28. 在卡夫卡實施唯一的消費者羣組編號
- 29. 卡夫卡0.9：消費者偏移向量的耐久性和持久性
- 30. 消費消費使用卡夫卡消費者 - Java
什麼卡夫卡的版本是您使用？作爲0.10，你可以請致電KafkaConsumer＃offsetsForTimes進行搜索預期的消息，如果你正在使用Java消費者。 – amethystic