カフカストリームのKStreamBuilder.fromの現在の方法は何ですか？

Question

私はhttp://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/streams/KafkaStreams.html

からサンプルコードをしようとしたが、この二行

KStreamBuilder builder = new KStreamBuilder(); 
builder.from("my-input-topic").mapValue(value -> value.length().toString()).to("my-output-topic"); 

のために今https://kafka.apache.org/0100/javadoc/org/apache/kafka/streams/kstream/KStreamBuilder.html

に応じKStreamBuilderの「から」と呼ばれる何の方法も思わないんだそうに現在の方法で何上記の2行と同じことをしますか？

Mavenはそれはドキュメントのバグです。このメソッドはstream()に名前が変更されました

<dependency> 
    <groupId>org.apache.kafka</groupId> 
    <artifactId>kafka-streams</artifactId> 
    <version>0.10.0.0</version> 
</dependency> 

Answer 1

依存関係（から（）が古い名前です）

KStreamBuilder builder = new KStreamBuilder(); 
builder.stream("my-input-topic").mapValues(value -> value.length().toString()).to("my-output-topic"); 

を管理するために使用されます。https://github.com/apache/kafka/pull/1450

こちらもご覧ください：http://docs.confluent.io/3.0.0/streams/developer-guide.html#kafka-streams-dsl