准备工作

1.安装kafka+zookeeper环境

2.利用命令创建好topic，创建一个topic my-topic

集成步骤

1.配置生产者

2.配置消费者

3.消息序列化和反序列化

在发送消息时，我们可以发送对象，而不只是字符串，所以我们需要将发送的数据进行序列化和反序列化，上面的配置文件有配置序列化和反序列化。

序列化代码

package com.redxun.jms;import java.util.Map;import org.apache.kafka.common.serialization.Serializer;import com.redxun.core.util.FileUtil;public class ObjectSerializer implements Serializer

反序列化

package com.redxun.jms;import java.util.Map;import org.apache.kafka.common.serialization.Deserializer;import com.redxun.core.util.FileUtil;public class ObjectDeSerializer implements Deserializer

4.发送消息代码

OsUser user=new OsUser();user.setUserId("00001");user.setFullname("zyg");kafkaTemplate.sendDefault("demo", user);

5.接收消息代码

package com.redxun.jms;import org.apache.kafka.clients.consumer.ConsumerRecord;import org.springframework.kafka.listener.MessageListener;import com.redxun.sys.org.entity.OsUser;public class KafkaConsumerListener implements MessageListener
     
       {    @Override    public void onMessage(ConsumerRecord
      
        record) {        if(record.value() instanceof OsUser ){            OsUser user=(OsUser) record.value();            System.out.println(user.getFullname());        }          }}