Kafka-spring-boot-starter: encapsulated based on spring-kafka

Last update: Jan 9, 2023

Overview

Encapsulation based on spring-kafka not only supports native configuration, but also adds multi data source configuration.

Intro

Kafka-spring-boot-starter is encapsulated based on spring-kafka. In addition to supporting native configuration, it also adds multi data source configuration.

QQ：908942659 ； wechat：xin2014555

Install

<dependency>
  <groupId>io.github.pg-liudonggroupId>
  <artifactId>kafka-spring-boot-starterartifactId>
  <version>1.0.0version>
dependency>

Features

Support native： Support spring-kafka native configuration.

spring:
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      auto-offset-reset: earliest
    producer:
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer

Support multiple data sources： Support multi data source configuration.(The smaller the configuration granularity, the higher the priority)

spring:
  kafka:
    multiple:
      # Primary data source is not allowed to be empty.
      primary: ds1  
      consumer:
        key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
        value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
        auto-offset-reset: latest
      producer:
        key-serializer: org.apache.kafka.common.serialization.StringSerializer
        value-serializer: org.apache.kafka.common.serialization.StringSerializer
      datasource:
        ds1:
          bootstrap-servers: localhost:9092
          consumer:
            # Consumer concurrent kafka listener container factory is not allowed to be empty.
            container-factory: ds1KafkaListenerContainerFactory  
            auto-offset-reset: earliest
          producer:
            kafka-template: ds1KafkaTemplate
        ds2:
          bootstrap-servers: localhost:9093
          consumer:
            container-factory: ds2KafkaListenerContainerFactory
            auto-offset-reset: earliest
          producer:
            # Producer kafka template bean name is not allowed to be empty.
            kafka-template: ds2KafkaTemplate

Demo

kafka-spring-boot-starter-demo

Donate

If you think the plug-in is great and saves you a lot of time, invite the author to have a cup of coffee~ ☕ ☕ ☕ , Thank you. Your support is the driving force to encourage us to move forward. No matter how much it is, it is enough to express your intention.

WeChat official account

Irregularly share the dry notes of programming technology, not limited to algorithms, databases, spring boot, microservices, high concurrency, JVM, docker, elk, programming skills and other related knowledge. We look forward to making progress with you!

Get or Throw Spring boot Starter will help you to hide handling if entity not found.

Get or Throw Spring boot Starter Get or Throw Spring boot Starter will help you to hide handling if entity not found. 1. Setup 2. Usage Library adds c

Feb 2, 2022

本项目基于springboot进行开发，实现了一系列的spring-boot-starter

项目简介本项目基于springboot进行开发，实现了一系列的spring-boot-starter，可以作为开发中的工具包进行使用。模块划分 common-spring-boot-starter：常用的基础类，比如用作消息流转的Msg以及一些工具类 monitor-spring-boot-st

Jan 24, 2022

End to End project for Kafka Streams using Spring Cloud Kafka streams

Spring Kafka Streams using Spring Cloud Streams End to End example Endpoint http://localhost:8080/domain/lookup/facebook - to pull all facebook relate

Dec 20, 2022

Spring Boot Login and Registration example with MySQL, JWT, Rest Api - Spring Boot Spring Security Login example

Spring Boot Login example with Spring Security, MySQL and JWT Appropriate Flow for User Login and Registration with JWT Spring Boot Rest Api Architect

Jan 5, 2023

Best practice of monolithic spring application starter

Jul 19, 2022

A Spring Boot Camel boilerplate that aims to consume events from Apache Kafka, process it and send to a PostgreSQL database.

SPRING-BOOT CAMEL BOILERPLATE This is a Spring-Boot Camel Application model that you can use as a reference to study or even to use in your company. I

Apr 4, 2022

Releases(v.1.0.5)

v.1.0.5(Mar 25, 2022)
Add support class

Source code(tar.gz)
Source code(zip)
v.1.0.4(Mar 22, 2022)
Optimize code.

Source code(tar.gz)
Source code(zip)
v.1.0.3(Mar 22, 2022)
Fix primary data source.

Source code(tar.gz)
Source code(zip)
v1.0.2(Mar 21, 2022)
Fix bootstrap servers.

Source code(tar.gz)
Source code(zip)
v1.0.1(Mar 15, 2022)
Fix the data source configuration to allow only one producer or consumer.

Source code(tar.gz)
Source code(zip)
v1.0.0(Mar 15, 2022)
Support spring-kafka native configuration.

Support multi data source configuration.

Source code(tar.gz)
Source code(zip)

Kafka-spring-boot-starter: encapsulated based on spring-kafka

Related tags

Overview

Intro

Install

Features

Demo

Donate

WeChat official account

You might also like...

Get or Throw Spring boot Starter will help you to hide handling if entity not found.

本项目基于springboot进行开发，实现了一系列的spring-boot-starter

End to End project for Kafka Streams using Spring Cloud Kafka streams

Spring Boot Login and Registration example with MySQL, JWT, Rest Api - Spring Boot Spring Security Login example

Best practice of monolithic spring application starter

A Spring Boot Camel boilerplate that aims to consume events from Apache Kafka, process it and send to a PostgreSQL database.

Spring Boot Debezium Kafka PostgreSQL Relationship

Microservices with Spring Boot and Kafka Demo Project

LOQUI - Real-time chat application built using Apache Kafka, Java, Spring Boot, SockJS and React

Releases(v.1.0.5)

v.1.0.5(Mar 25, 2022)

v.1.0.4(Mar 22, 2022)

v.1.0.3(Mar 22, 2022)

v1.0.2(Mar 21, 2022)

v1.0.1(Mar 15, 2022)

v1.0.0(Mar 15, 2022)

Owner

liudong

A springboot-starter that can achieve Intranet penetration. 一款可以实现内网穿透的springboot-starter。

A springboot-starter that can achieve Intranet penetration. 一款可以实现内网穿透的springboot-starter。

循序渐进，学习Spring Boot、Spring Boot & Shiro、Spring Batch、Spring Cloud、Spring Cloud Alibaba、Spring Security & Spring Security OAuth2，博客Spring系列源码：https://mrbird.cc

Spring Boot starter module for gRPC framework.

Spring Boot starter module for gRPC framework.

tuya-spring-boot-starter helps you efficiently create cloud development projects regarding the OpenAPI or message subscription capabilities. You can put all the focus on business logic without taking care of server-side programming nor relational databases.

Spring Boot starter for JustAuth Plus.

基于 spring-boot-starter-log4j2:2.6.1 (log4j 2.14.1)

An awesome Spring Boot Starter!

Create your Java crypto trading bot in minutes. Our Spring boot starter takes care of exchange connections, accounts, orders, trades, and positions so you can focus on building your strategies.