-
from beginning可以让消费者决定是否从头进行消费还是从中间进行消费。。。
控制台操作
查看全部 -
课程总结查看全部
-
0拷贝,好复杂查看全部
-
kafka的简单安装与使用 启动zk服务器 启动kafka服务器 创建topic 指定主机名 副本数,分区数, topic名称 启动生产者,指定broker-list topic名称 启动消费者,指定brootsddf localhost:9092,topic名称,offsets 此处的brootggg可以换成 zookeeper localhost:2181 offset --from-beginning从头开始消费 不加,就从当前位置开始消费查看全部
-
kafka应用场景 日志收集 流处理 事件源 持久性日志 commit log查看全部
-
kafka消息队列中,具体模型概念 offset 偏移量 4bytes length 最终长度,key value的和 4bytes rc32 类似于密码验证 MD5 1 magic wkafka对应的编号 可以快速过滤非kafka的消息 attribute 属性设置 1 timestamp 时间戳 8bytes key key值长度 4bytes key值 具体内容,长度不限 value value长度 4bytes value值 具体内容 长度不限查看全部
-
晕 zookeeper负责broker节点的管理 partition和replication的数据被zookeeper所记录 Consumer作用场景 hadoop集群 实时监控 数据仓库 其他应用查看全部
-
4类api Producer api Consumer api connectors api Stream Process api查看全部
-
暴露的两类接口 connectors 跟数据库进行交互 Stream Process 跟其他应用进行交互查看全部
-
kafka基本架构图 Producer application Consumer查看全部
-
replication 特点 增加容错性与可扩展性查看全部
-
replication的特点 基本单位是partition leader负责Producer和Consumer的读写,follower负责数据同步与备份 当leader挂掉,会自动选取follower为新的leader查看全部
-
broker挂掉,可以使用其他replication 副本初始为1,可根据需要自行设置 replication-factor查看全部
-
partition的具体概念查看全部
-
replication 副本 replication leader 副本领导者 只有一个副本会被使用,其余的用于数据的同步与备份 replicaManager 副本管理查看全部
举报
0/150
提交
取消