Kafka 如何在内部对分区内的消息进行排序?它是否按照从生产者那里收到的那样存储它们?
How does Kafka internally order the messages within a partition? Does it store them as it received from the producer?
我想了解 Kafka 在内部遵循的顺序,以便将消息放入从一堆不同的生产者那里收到的分区中。
分区是主题的分片。并且每个分区将写入同一目录下的单独文件,其中包含主题名称。写入或读取文件是顺序的,这是分区维护其顺序的方式。
Does it store them as it received from the producer?
是的,一旦收到消息,它就会被写入缓冲区,这与某些关系数据库写入预写日志非常相似。 Kafka使用操作系统的page cache作为缓冲区,以获得高性能的读写。 Kafka根据配置周期性的往文件中写入数据。
我想了解 Kafka 在内部遵循的顺序,以便将消息放入从一堆不同的生产者那里收到的分区中。
分区是主题的分片。并且每个分区将写入同一目录下的单独文件,其中包含主题名称。写入或读取文件是顺序的,这是分区维护其顺序的方式。
Does it store them as it received from the producer?
是的,一旦收到消息,它就会被写入缓冲区,这与某些关系数据库写入预写日志非常相似。 Kafka使用操作系统的page cache作为缓冲区,以获得高性能的读写。 Kafka根据配置周期性的往文件中写入数据。