Spring Cloud Stream with Kafka Binder

Hello everyone,
In this video, We will connect with Apache Kafka using Spring Cloud Stream's Kafka Binder approach.
It will be fun and exciting approach where you need very minimal configuration to work through your spring boot and Apache Kafka server.

[@swjny29]

Nice video..really its helped

[@anujsinghsomvanshi3385]

Nice Explanation. keep it up.👏

[@AtulMore-q8c]

Really nice example, simple explanation, easy to understand. Keep posting.

[@pandipalanichamy9319]

within 20 mins u taught very crystal clear about kafka unlike normal video tutorial

[@pco9556]

Coool. Nice cleared kafka-binder tutorial video thanks.

[@hariprakashreddym2595]

Nice topic, Very nice explanation, Thanks for your efforts.

[@kumaripuja7111]

It’s very precise. Thanks for sharing the knowledge. Please create more videos on Kafka stream processor.

[@Mohamed-uf5jh]

Great job , a good explanation thanks

[@h7sharma]

Glad it was helpful!

[@premraj.m]

6:30 kafkalytic pugin is nice...

[@playboxjrekong9186]

very nice !!!!

[@rohitmanohar2733]

Hi its very helpful video, Can u please add follow up video , like how to send custom object through Spring Cloud Stream and how to supply data coming from Rest endpoint to supply into kafka topic

[@test-nature]

Thank you very much. As begineer I understnad how we can start using Spring Cloud Stream with Kafka Binder

[@blueeyes9691]

nice, bread 👍

[@Dheeraj-i4n]

Hey I have some doubts !! After running the application can I able to change / switch the binder/ message broker with out stopping my application. If this is possible how can we do it

[@ankitmittal9034]

Question - What is the advantage of this over plain kafka consumers and producers. Also how is this different from KStreams and Spring Integration with Apache kafka ?

[@h7sharma]

Kafka binder is an abstraction over plain kafka, its advantage is in ease of configuration. If you are looking more fine grain control over your message production process you can opt for plain kafka/KafkaTemplate. Kstreams are focussed more on complex event processing.

[@himanshumahajan2405]

Hello, What if my consumer topic and producer topic are from different brokers ? How to configure that

[@h7sharma]

This might help - docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream-binder-kafka.html#_multi_binders_with_kafka_streams_based_binders_and_regular_kafka_binder

[@RahulSaini-pp5kz]

No files are shown in my kafkalytic plugin. What to do???

[@Madhavan2020]

Thanks you so much 👏👏👏👏👏👏

[@h7sharma]

You are welcome 😊

[@quantix5352]

Can I activate a specific spring.cloud.stream.function? For instance, if I have a REST Controller and want to send the request body to Kafka?

[@h7sharma]

You can conditionally activate the function using @ConditionalOnProperty. But, looking at the second part of your query seems StreamBridge might be a good option for you. Refer this link - docs.spring.io/spring-cloud-stream/docs/current/reference/html/spring-cloud-stream.html#_sending_arbitrary_data_to_an_output_e_g_foreign_event_driven_sources

[@brucereed1777]

I am not able to understand why the producer is adding message continuously at 22:49 in the logs. Am i missing anything ?

[@h7sharma]

Its because they are considered as infinite stream and are getting polled for data, refer - cloud.spring.io/spring-cloud-function/reference/html/spring-cloud-function.html#_function_composition

[@h7sharma]

Github link: github.com/himanshuntwk/spring-projects/tree/main/kafka-binder-demo

[@vineethchinna3951]

Thank you so much for the video very good explaination, If you have idea about securing microservices using okta/keyclock,instead of manually adding users in the keyclock/okta, can you please make a video how to connect it to any database and use databse details for authentication and authorization.

[@h7sharma]

​@@vineethchinna3951 Hi Vineeth, Thanks for your input. Regarding your keycloak scenario, is this what you are looking for - github.com/rsatrio/Keycloak-Federation-ExistingDB

[@vineethchinna3951]

@@h7sharma Thanks sharma for replyign to my quer yes I was looking for same, so do you have anything similar code repository which is implemented using springboot

[@h7sharma]

@@vineethchinna3951 No I don't have any upfront, but I will consider this and will work on it. Will definitely update you once ready :)

[@vineethchinna3951]

@@h7sharma Thank you so much, will be waiting for the video