Spring Cloud Stream with Kafka Binder
ฝัง
- เผยแพร่เมื่อ 13 ต.ค. 2024
- 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.
Nice Explanation. keep it up.👏
Nice video..really its helped
Really nice example, simple explanation, easy to understand. Keep posting.
within 20 mins u taught very crystal clear about kafka unlike normal video tutorial
It’s very precise. Thanks for sharing the knowledge. Please create more videos on Kafka stream processor.
Coool. Nice cleared kafka-binder tutorial video thanks.
Nice topic, Very nice explanation, Thanks for your efforts.
Great job , a good explanation thanks
Glad it was helpful!
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
very nice !!!!
6:30 kafkalytic pugin is nice...
Thank you very much. As begineer I understnad how we can start using Spring Cloud Stream with Kafka Binder
nice, bread 👍
No files are shown in my kafkalytic plugin. What to do???
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
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 ?
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.
Thanks you so much 👏👏👏👏👏👏
You are welcome 😊
Hello,
What if my consumer topic and producer topic are from different brokers ? How to configure that
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
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?
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
I am not able to understand why the producer is adding message continuously at 22:49 in the logs. Am i missing anything ?
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
Github link: github.com/himanshuntwk/spring-projects/tree/main/kafka-binder-demo
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.
@@vineethchinna3951 Hi Vineeth, Thanks for your input. Regarding your keycloak scenario, is this what you are looking for -
github.com/rsatrio/Keycloak-Federation-ExistingDB
@@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
@@vineethchinna3951 No I don't have any upfront, but I will consider this and will work on it. Will definitely update you once ready :)
@@h7sharma Thank you so much, will be waiting for the video