• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

“为”卡夫卡KStreams循环支持

apache-kafka 来源:Rakshitha Kademane 3次浏览

我需要知道如何使用“为”我的卡夫卡KStreams线环……下面是我的“for”循环需要被列入KStreams“为”卡夫卡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 loooks像

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

如何添加我上面的“for”循环到我KStreams


===========解决方案如下:

的东西是我用过value.split在“for”循环分裂我的数据.. ..所以,每当我的数据分裂它应该睡10ms左右…这是因为我需要我的数据来一个接一个

从你说你想要订购。要达到您的要求,您不需要sleep。它会工作。 Kafka Streams WordCount示例(我假设您的代码基于此示例)的作用相同:它也使用flatMapValues,传入平面贴图的lambda将文本行分割为单词。

除非我和其他人误解了你的问题(在这种情况下,你可能应该进一步澄清你的问题),我认为你不必要地复杂了你的代码。


版权声明:本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系管理员进行删除。
喜欢 (0)