Spring Boot Integration with Confluent Kafka

Payment Flow

Payment Processor Service

This service is going consume the message from Kafka topic , Refer kafka package for all the Consumer implementation. Kafka configuration is setup is application.properties.

Confluent Kafka Setup

• Sign up and Setup Confluent Account

• Sign into the Confluent Cloud Console

• Creating a new cluster

• After cluster creation - obtain Kafka cluster bootstrap server configuration

• Select Basic Authentication Mechanism and generate the API configuration

• Copy CLUSTER API KEY and CLUSTER API SECRET

• Update Kafka bootstrap server details, APIKEY and SECRET in project application.properties file.

Reference

Payment-ingestor - Producer application for sending the messages to this payment-processor

• Repository Link : https://github.com/pavan-bommideni/payment-ingestor

Tech Stack

Stack: Java 21, Spring boot, H2 , Confluent Kafka

Documentation

Confluent Kafka Documentation