如果我的kafkastreams应用程序中有一个共享变量,并且是由处理代码中的多个线程更新的,那么如何处理呢?我是否必须确保共享变量线程的安全,或者卡夫卡流库是这样处理的呢?在文档中的某个地方,我读到在运行Kafkastreams应用程序时,没有必要在线程之间进行协调。//update counter by multiple threads.如果这个
org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:400) ~[kafka-streams-:475) ~[kafka-streams-2.5.1.jar:na]
at org.apache.kafka.streams.processor.internals.TaskManager.process(StreamThread.java:6
我做过一些Kafka流应用程序和Kafka消费者应用程序。归根结底,Kafka流只是消费者,它消费来自Kafka的实时事件。所以我不知道什么时候使用Kafkastreams,或者为什么我们应该使用Kafkastreams,因为我们可以在消费者端执行所有的转换。我想了解Kafka stream和Kafka c