1、安装zookeeper、安装kafka
2、mvn引入spring-kafka
3、加入kafka配置
4、消费者使用@kafkalistener监听topic指定主题,生产者使用注入kafkatemplte调用send方法向kafka发送消息。
5、最底层是zookeeper,zookeeper下有多个node,每个node管理topic,topic管理多个分区,按topic分类将消息归类放入分区。
6、待续,未深入。。。
欢迎分享,转载请注明来源:内存溢出
1、安装zookeeper、安装kafka
2、mvn引入spring-kafka
3、加入kafka配置
4、消费者使用@kafkalistener监听topic指定主题,生产者使用注入kafkatemplte调用send方法向kafka发送消息。
5、最底层是zookeeper,zookeeper下有多个node,每个node管理topic,topic管理多个分区,按topic分类将消息归类放入分区。
6、待续,未深入。。。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)