Categorygithub.com/szq-123/golangpracticedemokafkakafka_single
package
0.0.0-20241220081035-1c36c8bd91a4
Repository: https://github.com/szq-123/golangpractice.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
2
Dependents
0
Files
121 SLOC

# Functions

No description provided by the author
MetadataTest 简单说, kafka集群的metadata包括: 所有broker的信息: ip和port; 所有topic的信息: topic name, partition数量, 每个partition的leader, isr, replica集合等 kafka集群的每一台broker都缓存了整个集群的metadata, 当broker或某一个topic的metadata信息发生变化时, 集群的Controller 都会感知到作相应的状态转换, 同时把发生变化的新的metadata信息广播到所有的broker;.
No description provided by the author