A. Kafka集群中的每台服务器叫Broker,整个集群由Zookeeper进行管理 B. Kafka采用发布订阅模式,每条消息都要发送到指定的Topic上 C. 每个Topic可分为多个Partition,这样可以提高Kafka的并发执行能力 D. Replica用于提高Kafka的扩展性,它分为Leader Replica、Follower Replica
A. Producer根据指定的partition方法,将消息发布到指定topic的partition B. Kafka集群接收到Producer发过来的消息后,将其持久化到硬盘,并保留消息指定时长,而不关注消息是否被消费 C. Kafka某个Topic的消息一旦被消费掉后,不会再被其他消费者重复消费 D. Kafka消费者可以指定从最早的offset开始消费,也可指定从最新的offset开始消费
A. leader B. ResourceManager C. follower D. controller
A. 通过索引信息可以快速定位 message B. 稀疏存储,即将原来的完整数据,只间隔的选择多条进行存储 C. 使index 元数据全部映射到 memory,可以避免 segment file 的 index 数据 IO 磁盘操作 D. 索引文件稀疏存储,可以大幅度降低 index 文件元数据占用空间大小
A. 仅有一次(Exactly Once) B. 最少一次(At Least Once) C. 最多三次(At Most Three Times) D. 最多一次(At Most Once)
A. 引入 Partition 机制,保证了 Kafka 的高吞吐能力 B. 每个 Partition 都是有序且不可变的消息队列 C. Partition 数量决定了每个 consumer group 中并发消费者的最大数量 D. 每个 Partition 在存储层面对应一个 log 文件
A. 删除Topic时,必须确保Kafka的服务配置delete.topic.enable配置为true B. Kafka安装及运行日志保存路径为/srv/Bigdata/Kafka C. Zookeeper服务不可用会导致Kafka服务不可用 D. 必须使用admin用户或者 Kafkamin组用户进行创建Topic
A. 将参数Config.Topology_ACKKRS设置为0 B. 将参数Config.Topology_ACKKRS设置为false C. Spout发送消息时,使用不指定消息messageID的接口进行发送 D. Bolt发送消息时使用Unanchor方式发送
A. Follower通过拉取的方式从Leader中同步数据 B. 主副本叫做Learder,从副本叫做Follower C. 消费者和生产者都是从Learder中读写数据,也可直接与Follower交互 D. 副本以分区为单位。每个分区都有各自的主副本的从副本
A. Producer负责生产数据。Consumer负责消费数据。Producer和Consumer之间需要建立连接 B. Producer既可以发送数据到Broker上。又可以发送数据到Consumer C. Producer作为消息生产者。可以直接将数据写入Zookeeper D. Producer连接任意一个正常的Broker实例就可以产生数据