您的位置:首页 > 游戏 > 手游 > kafka 入门

kafka 入门

2024/10/5 18:26:41 来源:https://blog.csdn.net/qq_41519442/article/details/141536953  浏览:    关键词:kafka 入门

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中了

消费者

在这里插入图片描述

在这里插入图片描述

查看消费者组的偏移量
在这里插入图片描述

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com