springboot整合kafka，指定分区发送，批量消费，指定topic分区消费.rar

【实例简介】
springboot2.x整合kafka，发送者包含自定义分区发送，发送之后的回调函数，消费者有两个监听，一个是批量消费多topic，另外一个是消费指定topic的不同分区
【实例截图】
【核心代码】
16359647636912116956.rar
└── springboot-kafka
├── pom.xml
├── springboot-kafka.iml
├── src
│   ├── main
│   │   ├── java
│   │   │   └── net
│   │   │   └── xdclass
│   │   │   └── base_project
│   │   │   ├── config
│   │   │   │   └── SpringConfigConstant.java
│   │   │   ├── consumer
│   │   │   │   ├── KafkaPartitionLintener.java
│   │   │   │   └── KafkaTopicLintener.java
│   │   │   ├── consumerConfig
│   │   │   │   └── KafkaConsumerConfig.java
│   │   │   ├── KafkaApplication.java
│   │   │   ├── producer
│   │   │   │   ├── KafkaSender.java
│   │   │   │   └── ProducerController.java
│   │   │   └── producerConfig
│   │   │   ├── KafkaProducerConfig.java
│   │   │   └── KafkaProducerPartitionConfig.java
│   │   └── resources
│   │   ├── application.properties
│   │   └── application.yml
│   └── test
│   ├── java
│   │   └── base_project
│   │   └── base
│   │   └── MQTest.java
│   └── resources
└── target
├── classes
│   ├── application.properties
│   ├── application.yml
│   ├── META-INF
│   │   └── springboot-kafka.kotlin_module
│   └── net
│   └── xdclass
│   └── base_project
│   ├── config
│   │   └── SpringConfigConstant.class
│   ├── consumer
│   │   ├── KafkaPartitionLintener.class
│   │   └── KafkaTopicLintener.class
│   ├── consumerConfig
│   │   └── KafkaConsumerConfig.class
│   ├── KafkaApplication.class
│   ├── producer
│   │   ├── KafkaSender$1.class
│   │   ├── KafkaSender.class
│   │   └── ProducerController.class
│   └── producerConfig
│   ├── KafkaProducerConfig.class
│   └── KafkaProducerPartitionConfig.class
├── generated-sources
│   └── annotations
├── generated-test-sources
│   └── test-annotations
├── maven-status
│   └── maven-compiler-plugin
│   └── compile
│   └── default-compile
│   ├── createdFiles.lst
│   └── inputFiles.lst
└── test-classes
└── base_project
└── base
└── MQTest.class

40 directories, 30 files