网站设计论文框架,2016年网站推广方法,呼和浩特建设网站,新网金商网站kafka 用途
业务中我们经常用来两个方面
1.发送消息
2.发送日志记录
kafka 结构组成
broker#xff1a;可以理解成一个单独的服务器#xff0c;所有的东西都归属到broker中
partation#xff1a;为了增加并发度而做的拆分#xff0c;相当于把broker拆分成不同的小块可以理解成一个单独的服务器所有的东西都归属到broker中
partation为了增加并发度而做的拆分相当于把broker拆分成不同的小块
topic:消息发送的必要条件把topic理解成插座板消息内容理解成电。
group消费者组可以理解成电器不同的电器插座上可以也一直插很多电器然后不同电器用电做不同的事。 kafka如何做到群发功能
消费者中可以指定消费者组当我们把消息发送到指定的topic上时不同的消费者组可以根据这个topic去拿到这个消息所以我们可以
指定多个消费者组然后消费同一个topic消费者组是电器不同的电器插座上可以也一直插很多电器然后不同电器用电做不同的事。
kafka 如何让消息按照我给的顺序消费
patation:可以保证加进来的消息都是按照顺序来推送的所以只需要能把消息发送到同一个partation上就行
那么kafka是如何保证发到哪个partation呢
1.指定partation
2.指定keykafka内部根据key求hash然后发送到kafka相同的key就可以落在同一个kafka上
但是我们大多数情况下都是指定key然后kafka内部去自动分配到不同的partation。
kafka 如何指定partation的数量
kafka的配置文件中conf/server.properties中通过replication-factor可以指定partation的数量
