从卡夫卡主题中读取有限相关记录列表的最佳方式是什么?例如,包含几百条记录的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. 卡夫卡主题websocket
- 5. 卡夫卡流:从多个分区主题阅读
- 6. 卡夫卡消费者无法从卡夫卡的主题订阅
- 7. 无法从卡夫卡主题读取消息使用Spark Streaming Kafka
- 8. 卡夫卡描述主题命令列表多个主题描述
- 9. 计算卡夫卡主题分区
- 10. 卡夫卡流:多主题分区
- 11. 卡夫卡经纪人与主题
- 12. 关联卡夫卡和动态主题
- 13. 卡夫卡主题分区火花流
- 14. 卡夫卡多个主题消费
- 15. 卡夫卡能够写入超过保留期限的主题
- 16. 卡夫卡流不读输入话题
- 17. 春季卡夫卡消费者:有没有使用卡夫卡0.8从多个分区读取的方法?
- 18. 卡夫卡中的同一主题的消费者数量是否有限制?
- 19. 弗林克读取卡夫卡
- 20. 卡夫卡没有在主题中均匀地填充分区
- 21. 卡夫卡重复读
- 22. 通过Java API获取和更新卡夫卡主题配置
- 23. 卡夫卡生产商生产数据的主题从PORT
- 24. 卡夫卡的__consumer_offsets和_schema主题有什么用?
- 25. 春季卡夫卡 - 所有主题到同一个消费者
- 26. 卡夫卡消费者 - 主题(S)具有较高优先级
- 27. 卡夫卡:从ZooKeeper获取经纪人主机
- 28. 卡夫卡消费者从磁盘读取缓存数据库
- 29. 卡夫卡流应用程序从写入分离读取
- 30. 卡夫卡Android问题
感谢您的信息。我正在评估kafka vs rabbitmq即将推出的项目。我看着ksql,但它在github的视线上说“dev only”。似乎尼朋的建议可能是要走的路。 – user2824203