项目如果需要引入kafka，可以从以下几个流程走：
1.pom文件引对应的jar包
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.9.2</artifactId>
<version>0.8.2.1</version>
</dependency>
有的项目还需要将对应使用kafka的包、类作为groupId、artifactId引入
例：
<!-- kafka -->
<!-- <dependency>
<groupId>com.xxx.bis</groupId>
<artifactId>OCC_KAFKA_Client</artifactId>
<version>0.0.1</version>
</dependency>-->
如果项目已经做了相应配置，则只需要引入最上面的jar包即可。
2.配置kafka
spring配置文件引入Kafka
基础配置完成之后，根据需求，分为生产者和消费者两种，无论哪种，都需要由运维先创建kafka主题。
并在application等配置信息中声明主题。
生产者
1）在需要的类中根据需求，引入Kafka，发送信息
@Autowired
private KafkaTemplate kafkaTemplate;
String topic = ConfigHelper.getString("运维创建的kafka主题");
//enrolment_web_space_modify_topic
System.out.println("kafka主题名:" + topic);
kafkaTemplate.send(topic, JsonHelper.toString(config));
消费者
1）进行消费者订阅配置
2.spring配置Kafka
3.业务订阅Kafka信息