Kafka Streams Example: read topic as table

topic-as-table.java

// Create KTable from Kafka topic.
KTable<String, String> table = builder.table("input-topic", Consumed.with(Serdes.String(), Serdes.String()));