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…

Retry feature is not working in Spring Batch I am expecting here that adding retryLimit() will retry the same chunk for n number of time on getting any exception If…stackoverflow.com Spring-batch : How to catch exception message with skip method in spring batch? I am a novice of spring batch. My question is how to catch exceptions with the skip method in spring-batch? As I know…stackoverflow.com The method stream(ItemStream) in the type AbstractTaskletStepBuilder > is not applicable for the… How to classify the elements using Spring Batch ? I want to write data into two different tables or files for now doing…stackoverflow.com

pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.7.0</version> <relativePath /> <!-- lookup parent from repository -->…

Kafka — Microservices Architecture Part-1 In this example, we’ll look at the ways to raise a message to Kafka when order is placed. pom.xml — All dependencies needed for the application. <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent>…

In this example, we’ll look at the Java 11 generics. Implementing a generic type public class AgeComparator implements Comparator<Person> Type Bound public class SortedPair<T extends Comparable<T>> Passing Parameter to generic type public class Reverser<T> implements Comparator<T> Person.java package com.example; import lombok.AllArgsConstructor; import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; …