springboot-kafka

安装配置Kafka ,Zookeeper

执行测试类可查看效果

 @Test
 public void kafkaSend() throws InterruptedException {
 //模拟发消息
 for (int i = 0; i < 5; i++) {
 User user = new User();
 user.setId(System.currentTimeMillis());
 user.setMsg(UUID.randomUUID().toString());
 user.setSendTime(new Date());
 kafkaSender.send(user);
 Thread.sleep(3000);
 }
 }

参考资料