分类 kafka面试题 下的文章


撰写于    浏览:1369 次  分类: kafka面试题
Kafka中有两种“保留策略”:一种是根据消息保留的时间,当消息在Kafka中保存的时间超过了指定时间,就可以被删除;另一种是根据Topic存储的数据大小,当Topic所占的日志文件大小大于一个阈值,则可以开始删除最旧的消息。Kafka会启动一个后台线程,定期检查是否存在可以删除的消息。“保留策略”的配置是非常灵活的,可以有全局的配置,也可以针对T[...]

撰写于    浏览:584 次  分类: kafka面试题
Kafka保证一个Partition内消息的有序性,但是并不保证多个Partition之间的数据有顺序。 每个Topic可以划分成多个分区( 每个Topic都至少有一个分区),同一Topic下的不同分区包含的消息是不同的。每个消息在被添加到分区时,都会被分配一个offset,它是消息在此分区中的唯一编号,Kafka 通过offset保证消息在分区内[...]

撰写于    浏览:792 次  分类: kafka面试题
Kafka支持Consumer的水平扩展能力。可以让多个Consumer加入一个Consumer Group(消费组),在一个Consumer Group中,每个分区只能分配给一个Consumer消费者,当Kafka服务端通过增加分区数量进行水平扩展后,可以向Consumer Group中增加新的Consumer来提高整个Consumer Grou[...]

撰写于    浏览:566 次  分类: kafka面试题
Kafka的每个Topic (主题)都可以分为多个Partition (分区),每个分区都有多个Replica(副本),实现消息冗余备份。每个分区中的消息是不同的,这类似于数据库中水平切分的思想,提高了并发读写的能力。而同一分区的不同副本中保存的是相同的消息,副本之间是一主多从的关系,其中Leader副本负责处理读写请求,Follower 副本则只[...]

撰写于    浏览:615 次  分类: kafka面试题
(1)在应用系统中可以将Kafka作为传统的消息中间件,实现消息队列和消息的发布订阅,在某些场景下,性能会超越RabbitMQ,ActiveMQ等传统的消息中间件。(2)Kafka也被用作系统中的数据总线,将其接人多个子系统中,子系统会将产生的数据发送到Kafka中保存,之后流转到目的系统中。(3)Kafka还可以用作日志收集中心,多个系统产生的日[...]