Kafka是什么 Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者在网站中的所有动作流数据。这种动作是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于。
怎么设置kafka topic数据存储时间 1、Kafka创建topic命令很简单,2113一条命令足5261矣:bin/kafka-topics.sh-create-zookeeper localhost:2181-replication-factor 3-partitions 3-topic test。2.此命令将创建一个4102名为test的topic,其中有1653三个分区,每个分区需要分配三个副本。三。topic创建主要分为两部分:命令行controller逻辑部分。四。后台逻辑将监听zookeeper下对应的目录节点。一旦启动topic创建命令,它将创建一个新的数据节点并触发后台创建逻辑。五个。确定分区副本分配方案(即,将每个分区副本分配给哪个代理);创建zookeeper节点并将此方案写入/brokers/topics/节点。五个。确定分区副本分配方案(即每个分区的副本分配给哪个分区)broker上);创建zookeeper节点,把这个方案写入/brokers/topics/节点下。6、Kafka controller这一部分的主要任务是:创建分区;创建副本;为每个分区选择leaderISR;更新各种缓存。
如何查看kafka 各partition数据量 若没有分区,一个topic对应的消息集在分布式集群服务组中,就会分布不均匀,即可能导致某台服务器A记录当前topic的消息集很多,若此topic的消息压力很大的情况下,服务器A。