# Demo 说明
本项目为基于 Spring Kafka 的动态配置消费者的 Demo，主要实现了以下功能：
1. 动态读取数据库配置连接 Kafka 地址
2. 动态创建 Kafka 消费者，并监听指定的 Topic
3. 可以通过调用接口动态增加或删除消费者
4. 可以通过调用接口动态启动或停止 Kafka 的消费程序
项目需要依赖 MySQL 数据库，所以需要先创建数据库和表。
修改配置文件 `application.yml` 中的数据库连接信息，然后执行下面 sql 创建 database:
```sql
CREATE DATABASE IF NOT EXISTS spring_kafka_example CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;
```
确保数据库连接正确后，由于项目使用了 Liquibase 进行数据库初始化和更新，所以只需要启动项目即可。
项目启动后可以访问 http://localhost:9898/doc.html 访问接口文档
spring_kafka_example.zip （61个子文件） 
spring_kafka_example 
.DS_Store 6KB pom.xml 4KB src .DS_Store 6KB test java com stackstone example spring kafka SpringKafkaExampleApplicationTests.java 248B send SendMessageTest.java 3KB main resources application.yml 2KB db sql init.sql 1KB changelog db.changelog-master.yml 82B 001-initial-database.yml 274B java com stackstone example spring kafka bo ClassMethodArgs.java 2KB repository KafkaConfigRepository.java 368B converter JsonToStringConverter.java 617B controller DynamicManageConsumerController.java 1KB consumer DynamicConsumer.java 1KB SimpleConsumer.java 1000B DemoDynamicConsumer.java 2KB service KafkaConsumerConfigService.java 1KB impl KafkaConsumerConfigServiceImpl.java 3KB entity KafkaConsumerConfig.java 1KB SpringKafkaExampleApplication.java 871B config KafkaConfig.java 5KB .idea GitlabLint.xml 405B jarRepositories.xml 845B codeStyles codeStyleConfig.xml 149B Project.xml 263B google-java-format.xml 176B vcs.xml 183B workspace.xml 5KB misc.xml 467B compiler.xml 720B intellij-javadocs-4.0.1.xml 6KB .gitignore 227B encodings.xml 186B target classes application.yml 2KB com stackstone example spring kafka bo ClassMethodArgs.class 5KB repository KafkaConfigRepository.class 495B converter JsonToStringConverter.class 2KB controller DynamicManageConsumerController.class 2KB consumer DemoDynamicConsumer.class 5KB DynamicConsumer.class 4KB SimpleConsumer.class 2KB service KafkaConsumerConfigService.class 678B impl KafkaConsumerConfigServiceImpl.class 4KB entity KafkaConsumerConfig.class 6KB config KafkaConfig.class 8KB SpringKafkaExampleApplication.class 1KB db sql init.sql 1KB changelog db.changelog-master.yml 82B 001-initial-database.yml 274B .DS_Store 8KB spring-kafka-example-0.0.1-SNAPSHOT.jar.original 8KB test-classes com stackstone example spring kafka send SendMessageTest.class 3KB SpringKafkaExampleApplicationTests.class 611B maven-status maven-compiler-plugin compile default-compile createdFiles.lst 198B inputFiles.lst 426B testCompile default-testCompile createdFiles.lst 140B inputFiles.lst 292B
spring-kafka-example-0.0.1-SNAPSHOT.jar 76.49MB maven-archiver pom.properties 86B generated-test-sources test-annotations generated-sources annotations spring-kafka-example.iml 520B README.md 868B资源评论
