-
69.Kafka 的网络模型是怎么样的？
69.Kafka 的网络模型是怎么样的？ 1）KafkaClient ，单线程 Selector 模型。 2）KafkaServer ，多线程 Selector 模型。 69.Kafka 的网络模型是怎么样的？ Kafka 基于高吞吐率和效率考虑，并没有使用第三方网络框架，而且自己基于 Java NIO 封装的。 1）KafkaClient... -
68.Kafka 的 high-level API 和 low-level API 的区别？
68.Kafka 的 high-level API 和 low-level API 的区别？ 68.Kafka 的 high-level API 和 low-level API 的区别？ High Level API 屏蔽了每个 Topic 的每个 Partition 的 offset 管理（自动读取Zookeeper 中该 Consumer g... -
74.Kafka 的消息格式是怎么样的？
74.Kafka 的消息格式是怎么样的？ 74.Kafka 的消息格式是怎么样的？ message 中的物理结构为： message 物理结构 参数说明： 关键字 解释说明 8 byte offset 在parition(分区)内的每条消息都有一个有序的id号，这个id号被称为偏移(offset),它可以唯一确定每条消息... -
80.消费端弄丢了数据？
80.消费端弄丢了数据？ 80.消费端弄丢了数据？ 唯一可能导致消费者弄丢数据的情况，就是说，你消费到了这个消息，然后消费者那边自动提交了 offset ，让 Broker 以为你已经消费好了这个消息，但其实你才刚准备处理这个消息，你还没处理，你自己就挂了，此时这条消息就丢咯。 这不是跟 RabbitMQ 差不多吗，大家都知道 Kafka 会自动提... -
59.Apache Kafka 是什么?
59.Apache Kafka 是什么? 59.Apache Kafka 是什么? Kafka 是基于发布与订阅 的消息系统 。它最初由 LinkedIn 公司开发，之后成为 Apache 项目的一部分。Kafka 是一个分布式的，可分区的，冗余备份的持久性的日志服务。它主要用于处理活跃的流式数据。 在大数据系统中，常常会碰到一个问题，整个大数据是... -
66.Kafka Producer 有哪些发送模式？
66.Kafka Producer 有哪些发送模式？ 66.Kafka Producer 有哪些发送模式？ Kafka 的发送模式由 Producer 端的配置参数 producer.type 来设置。 这个参数指定了在后台线程中消息的发送方式是同步的还是异步的，默认是同步的方式，即 producer.type=sync 。 如果设置成异步的模... -
65. Kafka 消息发送和消费的简化流程是什么？
65. Kafka 消息发送和消费的简化流程是什么？ 1）Producer 发送消息 2）Broker 存储消息 3）Consumer 消费消息 65. Kafka 消息发送和消费的简化流程是什么？ Kafka 消息发送和消费 1、Producer ，根据指定的 partition 方法（round-robin、hash等），将消息发布... -
73.为什么不能以 Partition 作为存储单位？
73.为什么不能以 Partition 作为存储单位？ 73.为什么不能以 Partition 作为存储单位？ 如果就以 Partition 为最小存储单位，可以想象，当 Kafka Producer 不断发送消息，必然会引起 Partition 文件的无限扩张，将对消息文件的维护以及已消费的消息的清理带来严重的影响，因此，需以 segment 为单... -
57.RabbitMQ 如何保证消息的顺序性？
57.RabbitMQ 如何保证消息的顺序性？ 57.RabbitMQ 如何保证消息的顺序性？ 和 Kafka 与 RocketMQ 不同，Kafka 不存在类似类似 Topic 的概念，而是真正的一条一条队列，并且每个队列可以被多个 Consumer 拉取消息。这个，是非常大的一个差异。 ? 来看看 RabbitMQ 顺序错乱的场景 ： 一个 ... -
63.Kafka 为什么要将 Topic 进行分区？
63.Kafka 为什么要将 Topic 进行分区？ 63.Kafka 为什么要将 Topic 进行分区？ 正如我们在 「聊聊 Kafka 的设计要点？」 问题中所看到的，是为了负载均衡，从而能够水平拓展。 Topic 只是逻辑概念，面向的是 Producer 和 Consumer ，而 Partition 则是物理概念。如果 Topic 不进...