Spring Cloud Stream with Kafka Binder 

Glad it was helpful!

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.

You are welcome 😊

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

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

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

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