首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
kafka
相关资讯
热门
最新
代码人生
01-01 08:00
代码人生
KafkaServer类比电信服务中心
KafkaServer类比电信服务中心 SocketServer相当于一个电信服务中心,Acceptor 线程相当于一个接线人员,负责接线。SocketChannel相当于一个建立好的传声筒,Processor相当于客服人员,负责处理用户通过SocketChannel这个传声筒发送过来的技术问题(读写请求)。Processor并不懂技术(如何处理读写请求),所以当他监听到SocketChann
113
后端
01-01 08:00
后端
Kafka
Kafka,消息队列有点对点方式和发布订阅方式消息队列作用有解耦、削峰、异步Kafka核心概念Broker:Kafka服务节点Topic:对消息进行分类Partition:对主题进行分区Replication:Leader和Flower,对分区备份Group:每个消费者组只能消费一条消息Docker安装Kafka安装zookeeperdockerpullwurstmeister/zookeeper
111
代码人生
01-01 08:00
代码人生
Kafka 消费者API
Kafka 消费者API 由于Kafka在消费过程中有可能会遇到断电宕机等故障,Consumer恢复后,需要从上次消费结束的地方接着消费,因此Kafka需要时刻记录Consumer消费到哪个offset,以便故障恢复后接着消费。 Kafka提供两种方法用来维护offset,
111
后端
01-01 08:00
后端
Kafka面试题!掌握它才说明你真正懂Kafka(附答案)
1、请说明什么是Apache Kafka? Apache Kafka是由Apache开发的一种发布订阅消息系统,它是一个分布式的、分区的和可复制的提交日志服务。 2、说说Kafka的使用场景? ①异...
108
后端
01-01 08:00
后端
kafka集群搭建
0. 服务器准备 服务器规划 IPhostname服务服务10.10.xxx.61kafka-01zookeeper-01kafka-0110.10.xxx.62kafka-01zookeeper-...
106
代码人生
01-01 08:00
代码人生
Kafka 生产者
Kafka 生产者,Kafka生产者Kafka生产者用于生产消息。通过前面的内容我们知道,Kafka的topic可以有多个分区,那么生产者如何将这些数据可靠地发送到这些分区?生产者发送数据的不同的分区的依据是什么?针对这两个疑问,这里简单记录下。为何要分区方便在集群中扩展,每个分区Partition可以通过调整以适应它所在的机器,而一个topic又可以有多个Partition组成,因此整个集群就可
105
代码人生
01-01 08:00
代码人生
kafka shell简单使用
kafka shell简单使用 将kafka添加到环境变量中 vim /etc/profile export KAFKA_HOME=/opt/iDataFusion/kafka export PATH=$PATH:$KAFKA_HOME/bin source /etc/profile 创建topic: --create: 指定创建topic动作 --topic:指定
104
后端
01-01 08:00
后端
Kafka 常用操作命令
Kafka 常用操作命令,Kafka常用操作命令操作命令查询系统的所有Topic#获取所有的主题./bin/kafka-topics.sh--list--zookeeperlocalhost:2181#或者./bin/kafka-topics.sh--bootstrap-serverlocalhost:9092--list#结果#__consumer_offsets#myTopic复制代码__co
102
后端
01-01 08:00
后端
Kafka成长3:Producer 元数据拉取源码原理(上)
Kafka成长3:Producer 元数据拉取源码原理(上),上一节我们分析了Producer的核心组件,我们得到了一张关键的组件图。你还记得么?简单概括下上面的图就是:创建了Metadata组件,内部通过Cluster维护元数据初始化了发送消息的内存缓冲器RecordAccumulator创建了NetworkClient,内部最重要的是创建了NIO的Selector组件启动了一个Sender线程
102
后端
01-01 08:00
后端
kafka表引擎使用
clickhouse使用kafka表引擎消费kafka数据
101
«
1
2
3
4
5
6
7
8
9
10
11
»