Pipe Code Sample

Provides sample code for a Pipe example.

The following is a Pipe code sample that moves records from an inputTopic to an outputTopic:

...
final StreamsBuilder builder = new StreamsBuilder();
KStream<String.String> source = builder stream(inputTopic);
source.to(outputTopic);
final Topology topology= builder.build();
final KafkaStreams streams=new KafkaStreams(topology, props);
...
streams.start();
...