Kafka streams 中处理数据, 之后的消息是否会等待前面的消息处理完

比如:在下述代码的RealTimeHandlerInstance::dataProcess部分,我处理这些消息会有一定的处理延时,那么当消息突然传来很多,之后的消息是否会等待前面消息处理完之后再处理?

KStream<String, String> kStream = streamsBuilder.stream("mqtt", Consumed.with(Serdes.String(), Serdes.String()));

        KTable<String, String> sameKeyAddStore =
                kStream.map((String k, String v) -> {

                    // 这里做了一些其他处理 

                    return new KeyValue<>(k1, k2);
                }).groupByKey().aggregate(
                        () -> "",
                        RealTimeHandlerInstance::dataProcess,
                        Materialized.as("SameKeyAddStore1")
                );

        //创建 kafkaStreams
        KafkaStreams kafkaStreams = new KafkaStreams(streamsBuilder.build(), streamsConfig);





发表于: 8月前   最后更新时间: 8月前   游览量:605
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • 评论…
    • in this conversation