/topic-as-stream.java
forked from miguno/topic-as-stream.java
Created Jan 9, 2020
Kafka Streams Example: read a topic as a stream
| // Create KStream from Kafka topic. | |
| StreamsBuilder builder = new StreamsBuilder(); | |
| KStream<String, String> stream = | |
| builder.stream("input-topic", Consumed.with(Serdes.String(), Serdes.String())); |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment