This example demonstrates, using the high-level KStream DSL, how to implement the WordCount program that computes a simple word occurrence histogram from an input text. This example uses lambda expressions and thus works with Java 8+ only. In this example, the input stream reads from a topic named “streams-plaintext-input”, where…

In this tutorial, I would demo Spring WebFlux Streaming Response (aka Server Sent Events) — a mechanism for pushing notifications or messages to the browsers from the back-end application in real time. These messages can be consumed by other services. Spring WebFlux Streaming: As old traditional architecture browsers or other service have to…

In this example, we’ll learn how to make the use of Redis cache when you’ve a requirement where 90% operations are HTTP GET (Read) and concurrency is high (may be 300 tps or more), then using Spring WebFlux Redis with R2DBC would be good choice. Say, user(s) is/are making (concurrent)…

In this example, will give an overview about Spring Cloud Stream, followed by one example on how simple it is to write Kafka Processor using Spring Cloud Stream. We’re using functional programming way to create topic (do not try in prod) and all spring cloud stream auto-configuration features will work. …

In this example, will give an overview about Spring Cloud Stream, followed by one example on how simple it is to write Kafka Processor using Spring Cloud Stream. We’re using functional programming way to create topic (do not try in prod) and all spring cloud stream auto-configuration features will work. …

In this tutorial, I will show you how to produce and consume messages to and from Confluent Kafka Rest. I can directly post messages using Postman or curl command. Please go through link and this will give you complete idea around Use Cases and Architectures for HTTP and REST APIs…

In this example, I will make the use of maxwell to raise an event when some records created/updated/delete and raised events will go to kafka and interested consumer will consume that event. Maxwell's Daemon This is Maxwell's daemon, an application that reads MySQL binlogs and writes row updates as JSON to Kafka, Kinesis, or…maxwells-daemon.io This is Maxwell’s daemon, an application that reads MySQL binlogs and writes row updates as JSON to Kafka…

Introduction Spring Cloud Function is a project with the following high-level goals: Promote the implementation of business logic via functions. Decouple the development lifecycle of business logic from any specific runtime target so that the same code can run as a web endpoint, a stream processor, or a task. Support a…

I’ve created the complete microservices tutorials that will help newbie to learn and understand the microservices stack Below example covers — Spring Cloud Config Server Spring Cloud APIGW Resilience4J — For circuit breaker Sleuth and Zipkin — For distributed tracing Database per service Keycloak — for Authentication and authorization Kafka…