從卡夫卡主題中讀取有限相關記錄列表的最佳方式是什麼?例如,包含幾百條記錄的db查詢結果。我怎麼會知道「結束」?標題中有簡單的標誌?卡夫卡從主題中讀取有限列表
0
A
回答
0
對於這種用例,Kafka不是一個好的選擇。您必須記住與DB查詢相對應的消息的開始和結束偏移量,並且還必須確保這些消息進入單個分區,否則它們可能會被添加到命令以及更多狀態中以便記憶。如果您爲每個查詢使用一個專用主題,那會更好。卡夫卡不是一個很好的選擇,即時創建和刪除主題。
相反,對於您提到的用例,Redis列表將是更好的選擇。
1
聽起來就像你試圖查詢卡夫卡。在這種情況下,您可能想嘗試KSQL(https://github.com/confluentinc/ksql)。它允許你創建類似SQL的查詢,如SELECT * FROM mytopic WHERE regionid LIKE'%_8'或者regionid LIKE'%_9'LIMIT 100;
相關問題
- 1. 卡夫卡python檢索主題列表
- 2. 列出所有卡夫卡主題
- 3. 如何從卡夫卡隊列直接從卡夫卡隊列讀取數據
- 4. 重複卡夫卡主題
- 5. 卡夫卡主題websocket
- 6. 卡夫卡流:從多個分區主題閱讀
- 7. 阿帕奇頂點 - 卡夫卡0.9安全卡夫卡主題
- 8. 卡夫卡消費者無法從卡夫卡的主題訂閱
- 9. 閱讀火花批處理作業中的卡夫卡主題
- 10. 無法從卡夫卡主題讀取消息使用Spark Streaming Kafka
- 11. 卡夫卡描述主題命令列表多個主題描述
- 12. 卡夫卡流:多主題分區
- 13. 卡夫卡經紀人與主題
- 14. 卡夫卡多個主題消費
- 15. 計算卡夫卡主題分區
- 16. 關聯卡夫卡和動態主題
- 17. 卡夫卡主題分區火花流
- 18. 卡夫卡流不讀輸入話題
- 19. 卡夫卡能夠寫入超過保留期限的主題
- 20. 春季卡夫卡消費者:有沒有使用卡夫卡0.8從多個分區讀取的方法?
- 21. 卡夫卡中的同一主題的消費者數量是否有限制?
- 22. 弗林克讀取卡夫卡
- 23. 卡夫卡沒有在主題中均勻地填充分區
- 24. 卡夫卡重複讀
- 25. 通過拒絕確認重新讀取來自卡夫卡主題的消息
- 26. 卡夫卡MirrorMaker的消費者不取出由主題
- 27. 通過Java API獲取和更新卡夫卡主題配置
- 28. 卡夫卡生產商生產數據的主題從PORT
- 29. 卡夫卡消費者 - 主題(S)具有較高優先級
- 30. 春季卡夫卡 - 所有主題到同一個消費者
感謝您的信息。我正在評估kafka vs rabbitmq即將推出的項目。我看着ksql,但它在github的視線上說「dev only」。似乎尼朋的建議可能是要走的路。 – user2824203