Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- //Not working
- KTable<String, Customer> customerKTable = streamsBuilder.table("customer", Consumed.with(Serdes.String(), customerSerde));
- customerKTable.foreach(((key, value) -> System.out.println("Customer from Topic: " + value)));
- //KStream working
- KStream<String, Customer> customerKStream= streamsBuilder.stream("customer", Consumed.with(Serdes.String(), customerSerde));
- customerKStream.foreach(((key, value) -> System.out.println("Customer from Topic: " + value)))
Add Comment
Please, Sign In to add comment
