kafka 有分区和副本的概念,partition = 3 表示有3个分区,replication = 2 表示有2个副本
通过 --describe --topic test命令可以知道 test这个 主题的分区和副本情况,途中的replicas 表示 其他副本分区的情况,如第一条,test 的partition = 0 分区主分区在partition=0,两外两个副本分区在 1和2 ,ISR表示,如果1和2同步的太慢也是会被踢出去的。
创建主题命令
kafka-topics.sh --create --topic test-kafka --bootstrap-server localhost:9092
# 集群的方式,创建topic
kafka-console-producer .sh --broker -list loca lhost :9092,loca lhost :9093,localhost :9093 --topic test
kafka 配置文件核心配置项
生产者
ack: all表示数据已经在leader和副本的 broker中了
消费者
查看消费者组的偏移量