Kafka Streams Example: read topic as table
// 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