1.配置pom包
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>
2.配置application.yml kafka部分：
kafka: # 指定kafka 代理地址，可以多個
bootstrap-servers: hadoop:9092, slave1:9092
template: # 指定默認topic id
default-topic: producer
listener: # 指定listener 容器中的線程數，用於提高並發量
concurrency: 5
consumer:
group-id: myGroup # 指定默認消費者group id
client-id: 200
max-poll-records: 200
auto-offset-reset: earliest # 最早未被消費的offset
producer:
batch-size: 10 # 每次批量發送消息的數量
retries: 3
client-id: 200
3.定義生產者類：
4.定義消費者類：
5.定義生產者controller:
