Spring Tips: Spring Cloud Stream Kafka Streams

[@jackdry5607]

don't often comment on yt videos, but this is so so helpful. Thanks a lot.

[@khalildureidy]

For new viewers, there are some deprecations since this video,:
1. spring.cloud.stream.bindings.pvout.producer.headerMode=none //Instead of raw
2. QueryableStoreRegistry is deprecated and a new API is provided called InteractiveQueryService
One bug:
String rName = names.get(new Random().nextInt(names.size())); //it was pages.get(**

[@adrianjason13]

Thanks. What's the purpose of header mode anyway?

[@khalildureidy]

@@adrianjason13 This is just to store meta data, think of it like HTTP request headers

[@essamal-mansouri2689]

@Input and @Output annotations were also deprecated in favor of functional methods instead to support streams.
Instead of using what was in the video exactly, I suggest going to their repo. I believe it was updated more recently (1-2 years ago but still).

[@JamalKhaffaf]

this tutorial made me feel, I live in the Stone Age

[@macarong35]

Me too :D

[@DavidAlonsoTorrejon]

Thanks for the upload! Great explanation

[@amolwalanj3116]

Is there any example which mention working with multiple nodes of applications for interactive Query?
Also working of Data store in case of one of the node goes down.

[@peavers]

Code can be found on Josh's Github profile here: github.com/joshlong/spring-cloud-stream-kafka-streams

[@CharlesRay87]

My favorite “hello world guy” :)

[@altugaecoffice]

can you post the repo to this demo?

[@igorski_co]

github.com/joshlong/spring-cloud-stream-kafka-streams

[@coffeesoftware]

also, github.com/spring-tips/spring-cloud-stream-kafka-streams

[@josephfouad3561]

Hi, Thanks for the great content :)
what is the status of kafka streams reactive support?

[@vicky271075]

What happens to KTable if server goes down, is it persisted like a topic?

[@coffeesoftware]

yep - the data is persisted in Kafka. No need for anything else :-)

[@andonglin8900]

found one typo: it should be 'commit.interval.ms' instead of 'commit.interval.mms' in application.properties.

[@mafouzekoto9122]

Hello! thanks for this nice Video!

[@coffeesoftware]

thanks so much for watching and I'm glad you got something out of it! :)

[@austin832]

Damn this guy is good.

[@coffeesoftware]

thanks so much! it's not me, really. It's Spring. It's so danged easy/powerful! I'm drunk with power and potential! muahahah. :)

[@easyappscompany]

Best Regards From Mexico City. Manuel Silva

[@Denilson.marcos]

Which planet did you came from?

[@vinu_varghese]

Good stuff, is the source code stored anywhere?

[@coffeesoftware]

yep. here ya go: github.com/spring-tips/spring-cloud-stream-kafka-streams :)

[@yunusarifsaid1788]

Forgive my ignorance, where is the real kafka topic name(that is created in kafka broker) set in this project ?

[@khalildureidy]

there are two topics, pcs, and pvs, they are specified in the config where ever you see **.destination=

[@adrianjason13]

I wish he also put this on Github.

[@AceHardy]

🚀💯

[@AnatolieLupacescu]

If the "pages" collection would have been smaller he could have had an IndexOutOfBoundsException thrown at some point in runtime.

[@MrDocomox]

That is a LOT of boilerplate code. It's really time to move to JavaScript if Java tools can't get zero configuration right in 2020