库特

0 声望

这家伙太懒,什么都没留下

个人动态
  • 半兽人 回复 库特KafkaStreams客户端(0.10.0.0 API) 中 :

    thanks,我更新一版。

    7年前
  • 订阅了 kafka 主题! · 7年前
  • 库特KafkaStreams客户端(0.10.0.0 API) 发表评论:

    version: 0.10.1

    Map<String, Object> props = new HashMap<>();
        props.put(StreamsConfig.APPLICATION_ID_CONFIG, "my-stream-processing-application");
        props.put(StreamsConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(StreamsConfig.KEY_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
        props.put(StreamsConfig.VALUE_SERDE_CLASS_CONFIG, Serdes.String().getClass().getName());
        StreamsConfig config = new StreamsConfig(props);
    
        KStreamBuilder builder = new KStreamBuilder();
        builder.stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic");
    
        KafkaStreams streams = new KafkaStreams(builder, config);
        streams.start();
    7年前