Skip to content

Instantly share code, notes, and snippets.

@miguno

miguno/topic-as-table.java

Last active January 9, 2020 07:56
Show Gist options
  • Save miguno/7dee4d17e13f7c0c29a04e58413a9f20 to your computer and use it in GitHub Desktop.
Save miguno/7dee4d17e13f7c0c29a04e58413a9f20 to your computer and use it in GitHub Desktop.
Download ZIP
Kafka Streams Example: read topic as table
Raw
topic-as-table.java
// Create KTable from Kafka topic.
KTable<String, String> table = builder.table("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