代码拉取完成，页面将自动刷新
Kafka面试题及答案【最新版】Kafka高级面试题大全(2021版)，发现网上很多Kafka面试题及答案整理都没有答案，所以花了很长时间搜集，本套Kafka面试题大全，Kafka面试题大汇总，有大量经典的Kafka面试题以及答案，包含Kafka语言常见面试题、Kafka工程师高级面试题及一些大厂Kafka开发面试宝典，面试经验技巧等，应届生，实习生，企业工作过的，都可参考学习!
工具类型
Apache Kafka 是面向多个生产商和消费者的通用工具。
Apache Flume 是特定应用程序的专用工具。
复制功能
Apache Kafka 可以复制事件；
Apache Flume 不复制事件。
offset+1
允许应用程序订阅一个或多个主题并处理生成给它们的记录流的API，我们称之为消费者API。
生产者在主题上发布消息：
1、 bin/Kafka-console-producer.sh --broker-list 192.168.43.49:9092 --topic Hello-Kafka
2、 注意这里的IP是server.properties中的listeners的配置。接下来每个新行就是输入一条新消息。
3、 消费者接受消息：
4、 bin/Kafka-console-consumer.sh --zookeeper localhost:2181 --topic Hello-Kafka --from-beginning
bin/Kafka-topics.sh --list --zookeeper localhost:2181
一个消费者组中的一个分片对应一个消费者成员，他能保证每个消费者成员都能访问，如
果组中成员太多会有空闲的成员
1、 Kafka 将消息以 topic 为单位进行归纳
2、 将向 Kafka topic 发布消息的程序成为 producers.
3、 将预订 topics 并消费消息的程序成为 consumer.
4、 Kafka 以集群的方式运行，可以由一个或多个服务组成，每个服务叫做一个 broker.
5、 producers 通过网络将消息发送到 Kafka 集群，集群向消费者提供消息
我们可以轻松地将Kafka部署为多租户解决方案。但是，通过配置主题可以生成或使用数据，可以启用多租户。此外，它还为配额提供操作支持。
1、 Kafka 持久化日志，这些日志可以被重复读取和无限期保留
2、 Kafka 是一个分布式系统：它以集群的方式运行，可以灵活伸缩，在内部通过复制数据
3、 提升容错能力和高可用性
4、 Kafka 支持实时的流式处理
初始化ZooKeeper服务器是非常重要的一步，因为Kafka使用ZooKeeper，所以启动Kafka服务器的过程是：要启动ZooKeeper服务器：>bin/zooKeeper-server-start.sh config/zooKeeper.properties接下来，启动Kafka服务器：>bin/Kafka-server-start.sh config/server.properties
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
