查看: 78|回复: 5

[Java新手区] 创建处理的拓扑

[复制链接]

该用户从未签到

发表于 2020-3-24 20:34:57 | 显示全部楼层 |阅读模式

  1. StreamsBuilder builder = new StreamsBuilder();
  2. KStream<String, String> simpleFirstStream = builder.stream("src-topic",
  3.     Consumed.with(stringSerde, stringSerde));
  4. // 使用KStream.mapValues方法把每行输入转换为大写
  5. KStream<String, String> upperCasedStream = simpleFirstStream.mapValues(line -> line.toUpperCase());
  6. // 把转换结果输出到另一个topic
  7. upperCasedStream.to("out-topic", Produced.with(stringSerde, stringSerde));
复制代码

  • TA的每日心情
    开心
    2015-3-20 14:37
  • 签到天数: 1 天

    [LV.1]初来乍到

    发表于 2020-3-25 21:09:03 | 显示全部楼层
    StreamsBuilder

    该用户从未签到

    发表于 2020-3-28 16:35:15 | 显示全部楼层
    StreamsBuilder

    该用户从未签到

    发表于 2020-4-1 22:12:56 | 显示全部楼层
    stringSerde
  • TA的每日心情
    开心
    2015-3-20 14:37
  • 签到天数: 1 天

    [LV.1]初来乍到

    发表于 昨天 21:51 | 显示全部楼层
    stringSerde
    您需要登录后才可以回帖 登录 | 注册青鸟豆号

    本版积分规则

    Copyright 1999-2020 Beijing Aptech Beida Jade Bird Information Technology Co.,Ltd

    北大青鸟IT教育 北京阿博泰克北大青鸟信息技术有限公司 版权所有

    京ICP备11045574号-3 京公网安备11010802013845号

    快速回复 返回顶部 返回列表