北京找一家大数据培训机构去哪报名呢

Kafka常见面试问题总结

发布：大数据培训来源：大数据教程时间：2020-10-15 16:16分享到：

现如今，Kafka已不再是一个单纯的消息队列系统。Kafka是一个分布式的流处理平台，被越来越多的公司使用，Kafka可以被用于高性能的数据管道，流处理分析，数据集成等场景。本文分享总结了几个Kafka常见的面试问题，希望对你有所帮助。主要包括以下内容：

Kafka是如何保障数据不丢失的？

如何解决Kafka数据丢失问题？

Kafka可以保障不丢失数据吗？

如何保障Kafka中的消息是有序的？

如何确定Kafka主题的分区数量？

如何调整生产环境中Kafka主题的分区数量？

如何重平衡Kafka集群？

如何查看消费者组是否存在滞后消费？

Q1：Kafka是如何保障数据不丢失的？该问题已经成为了Kafka面试的惯例，如同Java的HashMap，属于高频出现的面试问题。那么，我们该怎么理解这个问题呢？问题是Kafka如何保障数据不丢失，即Kafka的Broker提供了什么机制增加数据不丢失的。其实对于Kafka的Broker而言，Kafka的复制机制和分区的多副本架构是Kafka可靠性增加的核心。把消息写入多个副本可以使Kafka在发生崩溃时仍能增加消息的持久性。搞清楚了问题的核心，再来看一下该怎么回答这个问题：主要包括三个方面

1.Topic副本因子个数：replication.factor>=32.同步副本列表(ISR)：min.insync.replicas=23.禁用unclean选举：unclean.leader.election.enable=false