# dynamic-db-kafka

**Repository Path**: wu_feifan/dynamic-db-kafka

## Basic Information

- **Project Name**: dynamic-db-kafka
- **Description**: 用来接入消费第三方的kafka消费信息     Spring Boot 3 + Kafka + Dynamic DB (PostgreSQL/ClickHouse) + MyBatis + MyBatis Plus
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 1
- **Created**: 2025-08-30
- **Last Updated**: 2025-09-08

## Categories & Tags

**Categories**: Uncategorized

**Tags**: Kafka, dynamic, 动态数据源

## README

此服务旨在创建一个kafka服务，切换动态数据源保存数据 因业务需要，在gitee上没找到合适的 其他功能太多我也不要 所以写了一下
kafka接入第三方，动态数据源
技术栈:
jdk21
springboot 3.2.0
mapstruct 3.1.0

使用mybatisPlus 只要按照mybatis plus的要求来创建实体类，mapper类，service类，controller类，
创建对应的xml文件，即可完成

上手需要修改的地方 !!!! 请看下面

这里使用了jaas的账密 不需要你就去掉
![img.png](img.png)

需要修改的数据库连接
![img_1.png](img_1.png)

需要修改的kafka连接
![img_2.png](img_2.png)

然后就启动就可以了，我删除了业务代码，只保留了demo，亲测可用哈