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