apache-kafka - 如何从 kafka 中读取已经提交的消息
问题描述
我对 kafka 有要求,想从 kafka 中读取已经提交的消息而不是所有消息
解决方案
使用 spring-kafka,实现ConsumerSeekAware
,您可以在启动期间寻求任何您喜欢的偏移量。
请参阅文档。
推荐阅读
- javascript - mysql在控制台中抛出错误并停止nodejs服务器
- reactjs - A View is partially hidden after wrapped by TouchableOpacity
- firebase - Flutter Apple 登录 - 空电子邮件
- python - Python Flask:{% include ...%} 中的变量
- c++ - 如何在 GPU 内核中使用特征稀疏矩阵
- javascript - gscript 在尝试将 csv 保存到谷歌表时没有选择最新的邮件
- sql-server - 如何将“类型”作为输入参数传递给 Postgresql 中的 func
- c++ - C++ 中递增全局变量与局部变量之间的行为差异
- javascript - 在多维数组中搜索具有匹配值的对象
- arrays - 如何使用 laravel 将多个数组插入 mysql