文件名称：kafka-streams-sad-state-store
文件大小：65KB
文件格式：ZIP
更新时间：2024-05-19 07:36:48
Java
卡夫卡州立商店问题 问题 即使启用了一次精确的传递，状态存储也不会与正在处理的记录保持同步。 考虑以下： 收到记录N 记录的身份保存到状态存储（用于业务级重复数据删除） 处理将引发异常，杀死该节点并确保不发送任何传出记录 预期的行为： 节点重启 偏移量从未更新，因此记录N被重新处理 状态存储区重置为位置N-1 记录已重新处理 实际行为 节点重启 记录N已重新处理（良好） 状态存储区具有先前处理中的状态 伤心的:( 在这种情况下，状态存储使应用程序认为重新运行消息显然是重复的，而显然不是 概念证明 nb清除rocksdb存储，运行make reset 在至少3个控制台中（按此顺序：） （控制台1） make kafka与Kafka和Zookeeper一起旋转docker-compose，配置为一次 （控制台2） make topology该应用将初始化其主题并等待记录 （
【文件预览】：
kafka-streams-sad-state-store-master
----topology()
--------src()
--------build.gradle(230B)
----gradlew(5KB)
----settings.gradle(75B)
----client()
--------src()
--------build.gradle(228B)
----LICENSE(1KB)
----gradle()
--------wrapper()
----Makefile(281B)
----gradlew.bat(2KB)
----docker-compose.yml(945B)
----.gitignore(22B)
----readme.md(1KB)
----build.gradle(232B)