apache-kafka - 在 KTable 中查找特定值
问题描述
我有一个 Kafka 主题。我有一个流，键是股票代码，值是高/低 pojo。我还有一个捕获流当前状态的 KTable。
我想一一处理流中的每条记录。对于每条记录，我想从 KTable 中查找该符号的当前值。然后根据 Hi/Low 是否变化，我想更新 KTable，然后将消息写入流。
解决方案
推荐阅读
- sql - SQL关于如何列出单年下单超过30单的客户
- oracle - 如何按修改时间对 Oracle 表进行排序
- c# - XmlSerializer 引发异常“System.InvalidOperationException”
- mysql - 通过 max(date) 获取记录，其中 date 可以为 null
- html - 跨浏览器字体高度
- ubuntu - 在 ubuntu 中安装 hybris b2b 时出错
- ios - 使用限制最大尺寸的约束在大型 UINavigationBar 中自定义视图
- javascript - Ajax 帖子为空 [Laravel]
- java - ArrayList 不会显示其元素
- python - 从 DataFrame 中获取数据并将其传递给一个新的空 DataFrame