'for' Kafka Streams 中的循环支持

Question

我需要知道如何在我的 kafka KStreams 行中使用 'for' 循环...下面是我的 'for' 循环，它需要包含在 KStreams

中

for (int i = 0; i < 6 ; i++) {
            try {
                textlines.flatMapValues(value -> Arrays.asList(value.split("\},\{")));
                Thread.sleep(2000);
            }catch (InterruptedException e){
                e.printStackTrace();
            }
        }

我的 KStreams 看起来像

KStream<String, String> textlines = builder.stream("intopic");
KStream<String, String> mstream = textlines
                .mapValues(value -> value.replace("[","" ) )

如何将我上面的 'for' 循环添加到我的 KStreams

Answer 1

the thing is i have used value.split in 'for' loop to split my data....so whenever my data get split it should sleep for about 10ms...this is because i need my data to come one after the other

根据你说的要点菜。要实现排序，您不需要 sleep。它会起作用的。我假设您的代码基于的 Kafka Streams WordCount 示例以相同的方式工作：它也使用 flatMapValues，并且传递到平面地图中的 lambda 将文本行拆分为单词。

除非我和其他人误解了您的问题（在这种情况下您或许应该进一步澄清您的问题），否则我认为您不必要地使代码复杂化。

'for' Kafka Streams 中的循环支持

'for' loop support in Kafka KStreams

apache-kafka

apache-kafka-streams