# Spring Kafka Dynamic Consumer Sample
Sample application of dynamically creating and deleting a kafka consumer (Listener container).
## How to Run
```sh
./mvnw spring-boot:run
```
springboot 基于spring-kafka动态创建kafka消费者
需积分: 5 188 浏览量
2023-11-17
16:17:01
上传
评论
收藏 192KB RAR 举报
springboot 基于spring-kafka动态创建kafka消费者 （194个子文件） 
16e9f00c3fd558c419a8483520ffade1c9d9ba 136B 22df60d244dc2ddc9b80bbdd3c5c9d5b62223e 421B 4428d89f03d7c868177c84630bac9164964acb 151B 683b3361f1c6182f09778dc08882620c73533c 141B 77f620ca43f6c686ce01853e9c957c62c807f4 154B 8235467a678922eabb5281351a46cc7efd4c2f 416B 840b9b93336ea17d4209c014619643bea77113 145B 87b8f740894a3e879b3c51f9a7aad73313c34c 154B b35327e718aebd70cbe42be2d216d63006bbbe 187B c41bf3d9cbaba2a020033b7e748241a12c2e77 145B KafkaConsumerController.class 10KB KafkaListenerContainerManager.class 7KB KafkaConsumerResponse.class 5KB KafkaMessageInputHandlerContext.class 4KB BatchStringMessageListener.class 3KB SpringKafkaDynamicConsumerApplicationTests.class 3KB FiledValueCheckFillHandler.class 3KB JsonRootBean.class 3KB KafkaConsumerAssignment.class 3KB UnderlineCaseHandler.class 3KB KafkaConsumerResponse$KafkaConsumerResponseBuilder.class 3KB KafkaConsumerRequest.class 2KB StringMessageListener.class 2KB KafkaConsumerAssignment$KafkaConsumerAssignmentBuilder.class 2KB FieldCopyHandler.class 2KB KafkaMessageInputHandlerFactory.class 2KB AbstractKafkaMessageInputHandler.class 2KB SpringKafkaDynamicConsumerApplication.class 839B KafkaMessageInputHandler.class 398B mvnw.cmd 7KB config 337B d1fb8187a92bd172cfd8c31608dca0758b6f41 153B description 73B exclude 240B .gitignore 428B HEAD 196B HEAD 196B HEAD 30B HEAD 21B pack-991fd6276c400dab4ff1ca979c372827f4aaa04d.idx 2KB spring-kafka-dynamic-consumer.iml 12KB index 3KB classpath.index 218B classpath.index 130B KafkaConsumerController.java 5KB KafkaListenerContainerManager.java 4KB SpringKafkaDynamicConsumerApplicationTests.java 2KB KafkaMessageInputHandlerFactory.java 1KB FiledValueCheckFillHandler.java 1KB AbstractKafkaMessageInputHandler.java 1KB UnderlineCaseHandler.java 1KB FieldCopyHandler.java 1KB BatchStringMessageListener.java 1022B KafkaMessageInputHandlerContext.java 873B StringMessageListener.java 785B KafkaConsumerRequest.java 546B KafkaConsumerResponse.java 430B KafkaMessageInputHandler.java 427B SpringKafkaDynamicConsumerApplication.java 380B KafkaConsumerAssignment.java 319B JsonRootBean.java 288B main 196B main 41B README.md 193B mvnw 10KB pack-991fd6276c400dab4ff1ca979c372827f4aaa04d.pack 63KB packed-refs 112B application.properties 401B application.properties 401B pack-991fd6276c400dab4ff1ca979c372827f4aaa04d.rev 204B pre-rebase.sample 5KB fsmonitor-watchman.sample 5KB update.sample 4KB push-to-checkout.sample 3KB sendemail-validate.sample 2KB pre-commit.sample 2KB prepare-commit-msg.sample 1KB pre-push.sample 1KB commit-msg.sample 896B pre-receive.sample 544B applypatch-msg.sample 478B pre-applypatch.sample 424B pre-merge-commit.sample 416B post-update.sample 189B workspace.xml 11KB uiDesigner.xml 9KB pom.xml 2KB jarRepositories.xml 1KB compiler.xml 941B Maven__org_springframework_boot_spring_boot_test_autoconfigure_2_1_7_RELEASE.xml 850B Maven__org_springframework_boot_spring_boot_starter_logging_2_1_7_RELEASE.xml 829B Maven__org_springframework_boot_spring_boot_starter_tomcat_2_1_7_RELEASE.xml 822B Maven__org_springframework_boot_spring_boot_autoconfigure_2_1_7_RELEASE.xml 815B Maven__com_fasterxml_jackson_module_jackson_module_parameter_names_2_9_9.xml 810B Maven__org_springframework_boot_spring_boot_starter_json_2_1_7_RELEASE.xml 808B Maven__org_springframework_boot_spring_boot_starter_test_2_1_7_RELEASE.xml 808B Maven__org_springframework_boot_spring_boot_starter_web_2_1_7_RELEASE.xml 801B Maven__org_springdoc_springdoc_openapi_starter_webmvc_api_2_0_2.xml 792B Maven__org_springdoc_springdoc_openapi_starter_webmvc_ui_2_0_2.xml 785B Maven__com_vaadin_external_google_android_json_0_0_20131108_vaadin1.xml 781B共 194 条
- 1
- 2
资源评论
