卡夫卡流状态存储是为了什么?
Kafka streams state store for what?
正如我从书中得到的那样,Kafka Streams state store 它是一个内存 key/value 存储,用于将数据存储到 Kafka 或过滤后。
被一些理论问题搞糊涂了
- Kafka 流状态与 Redis 等其他内存存储有何不同?
- 在 Kafka Streams 中使用状态存储的真实案例是什么?
- 为什么主题不能替代状态存储?
Why topic is not alternative for state storage?
主题包含按顺序排列的消息,通常表示日志。
有时,我们希望聚合这些消息,将它们分组并执行一个操作,例如 sum,例如 并将其存储在一个地方,我们稍后可以使用键。在这种情况下,理想的解决方案是使用键值存储而不是日志结构的主题。
What is real case to use state storage in Kafka Streams?
一个简单的用例是 word count where we have a word and a counter of how many times it has occurred. You can see more examples at kafka-streams-examples on github。
What is difference between Kafka streams state from another memory storage like Redis etc?
状态可以被视为一个保存点,您可以从那里恢复数据处理,或者它还可能包含一些需要进一步处理的有用信息(比如我们之前的字数统计需要递增),所以可以使用Redis、RocksDB、Postgres等存储
Redis 可以作为 Kafka 流状态存储的 插件,但是 Kafka 流的默认持久化状态存储是 RocksDB.
因此,Redis 不是 Kafka 流状态的替代品,而是 Kafka 流状态的替代品 RocksDB.
正如我从书中得到的那样,Kafka Streams state store 它是一个内存 key/value 存储,用于将数据存储到 Kafka 或过滤后。
被一些理论问题搞糊涂了
- Kafka 流状态与 Redis 等其他内存存储有何不同?
- 在 Kafka Streams 中使用状态存储的真实案例是什么?
- 为什么主题不能替代状态存储?
Why topic is not alternative for state storage?
主题包含按顺序排列的消息,通常表示日志。
有时,我们希望聚合这些消息,将它们分组并执行一个操作,例如 sum,例如 并将其存储在一个地方,我们稍后可以使用键。在这种情况下,理想的解决方案是使用键值存储而不是日志结构的主题。
What is real case to use state storage in Kafka Streams?
一个简单的用例是 word count where we have a word and a counter of how many times it has occurred. You can see more examples at kafka-streams-examples on github。
What is difference between Kafka streams state from another memory storage like Redis etc?
状态可以被视为一个保存点,您可以从那里恢复数据处理,或者它还可能包含一些需要进一步处理的有用信息(比如我们之前的字数统计需要递增),所以可以使用Redis、RocksDB、Postgres等存储
Redis 可以作为 Kafka 流状态存储的 插件,但是 Kafka 流的默认持久化状态存储是 RocksDB.
因此,Redis 不是 Kafka 流状态的替代品,而是 Kafka 流状态的替代品 RocksDB.