我正在使用 Kafka stream 处理json数据流。我想做两件事。cassandra说，将所有数据持久化到数据存储中。执行基于窗口的计算来识别一些模式，并且只将感兴趣的模式持久化到另一个表中。有没有可能在同一时间内完成这两项活动 Kafka stream 消费者和重定向各自的输出到2个表？
Kafka stream
fhg3lkii1#
例如，您可以 peek 在kstream上-它将执行有副作用的操作（写入cassandra），并返回未更改的流，您可以对其执行必要的计算。请参阅有关使用示例的文档（遗憾的是，没有指向小节的链接）。
peek
1条答案
按热度按时间fhg3lkii1#
例如，您可以
peek在kstream上-它将执行有副作用的操作（写入cassandra），并返回未更改的流，您可以对其执行必要的计算。请参阅有关使用示例的文档（遗憾的是，没有指向小节的链接）。