-
71.Kafka 的数据存储模型是怎么样的?
71.Kafka 的数据存储模型是怎么样的? 71.Kafka 的数据存储模型是怎么样的? Kafka 每个 Topic 下面的所有消息都是以 Partition 的方式分布式的存储在多个节点上。同时在 Kafka 的机器上，每个 Partition 其实都会对应一个日志目录，在目录下面会对应多个日志分段（LogSegment）。 MacBook ... -
31.Kafka监控（上）
Kafka监控 监控数据的来源 OneMinuteRate 获取监控指标 Kafka监控 任何应用功能再强大、性能再优越，如果没有与之匹配的监控，那么一切都是虚无缥缈的。监控不仅可以为应用提供运行时的数据作为依据参考，还可以迅速定位问题，提供预防及告警等功能，很大程度上增强了整体服务的鲁棒性。 目前的 Kafka 监控产品有很多，比如 Kaf... -
28.Kafka Connect
Kafka Connect 独立模式 REST API 分布式模式 Kafka Connect Kafka Connect 是一个工具，它为在 Kafka 和外部数据存储系统之间移动数据提供了一种可靠的且可伸缩的实现方式。Kafka Connect 可以简单快捷地将数据从 Kafka 中导入或导出，数据范围涵盖关系型数据库、日志和度量数据、Ha... -
18.查看、修改和删除主题
查看主题 修改主题 删除主题 查看主题 第16节中提及了 kafka-topics.sh 脚本有5种指令类型：create、list、describe、alter 和 delete。其中 list 和 describe 指令可以用来方便地查看主题信息，在前面的内容中我们已经接触过了 describe 指令的用法，本节会对其做更细致的讲述。 通过... -
4.序列化-分区器-拦截器
序列化 分区器 生产者拦截器 序列化 生产者需要用序列化器（Serializer）把对象转换成字节数组才能通过网络发送给 Kafka。而在对侧，消费者需要用反序列化器（Deserializer）把从 Kafka 中收到的字节数组转换成相应的对象。在代码清单3-1中，为了方便，消息的 key 和 value 都使用了字符串，对应程序中的序列化器也使... -
90.kafka的优缺点
✅ Kafka 的优点 ❌ Kafka 的缺点 📊 消息队列对比表 📌 适用场景推荐 好的，我帮你整理一下 Kafka 的优缺点 ，用简洁明了的中文表述： ✅ Kafka 的优点 高吞吐量 Kafka 在单机上就可以处理百万级 TPS，适合大规模数据流处理。 低延迟 Kafka 设计上采用顺序写磁盘 + 页缓存，消息写入和消费延迟... -
27.常用管理工具
消费组管理 消费位移管理 手动删除消息 消费组管理 在 Kafka 中，我们可以通过 kafka-consumer-groups.sh 脚本查看或变更消费组的信息。我们可以通过 list 这个指令类型的参数来罗列出当前集群中所有的消费组名称，示例如下（这个功能对应 KafkaAdminClient 中的 listConsumerGroups() ... -
76.ZooKeeper 在 Kafka 中起到什么作用？
76.ZooKeeper 在 Kafka 中起到什么作用？ 76.ZooKeeper 在 Kafka 中起到什么作用？ 在基于 Kafka 的分布式消息队列中，ZooKeeper 的作用有： 1、Broker 在 ZooKeeper 中的注册。 2、Topic 在 ZooKeeper 中的注册。 3、Consumer 在 ZooKeepe... -
64.Kafka 的应用场景有哪些？
64.Kafka 的应用场景有哪些？ 64.Kafka 的应用场景有哪些？ Kafka 的应用场景 1）消息队列 比起大多数的消息系统来说，Kafka 有更好的吞吐量，内置的分区，冗余及容错性，这让 Kafka 成为了一个很好的大规模消息处理应用的解决方案。消息系统一般吞吐量相对较低，但是需要更小的端到端延时，并常常依赖于 Kafka 提供的... -
88.为什么kafka这么快
为什么Kafka这么快？ 一、顺序IO 二、内存映射文件 三、零拷贝 四、应用层面的优化 写在后面 为什么Kafka这么快？ 很多人都知道Kafka吞吐量高，延迟低，那么为什么Kafka会这么快？如果在面试中被问到这个问题，你会回答吗？如果你一脸懵逼地看着面试官，面试官可能不会很生气，但是后果可能很严重。因为在面试官的眼里，你可能只是个会写...