Kafka面试高频题目与详细答案

Kafka面试高频题目与详细答案

一、单选题（每题2分，共20分）

1.Kafka中，Topic的分区数量在创建后可以改变吗？（）A.可以随意增减B.只能增加不能减少C.只能减少不能增加D.不可以改变【答案】B【解析】Kafka中Topic的分区数量在创建后只能增加不能减少

2.Kafka中，消费者组（ConsumerGroup）的概念是什么？（）A.每个消费者属于一个独立的组B.同一组内的消费者共享订阅的Topic数据C.消费者组内不允许有重名的消费者D.消费者组只能包含一个消费者【答案】B【解析】同一组内的消费者共享订阅的Topic数据，实现数据分摊

3.Kafka中，Producer发送消息的确认机制有哪些级别？（）A.无确认B.确认收到BrokerC.确认收到副本D.以上都是【答案】D【解析】Producer发送消息的确认机制包括无确认、确认收到Broker和确认收到副本

4.Kafka中，哪些是ZooKeeper的作用？（）A.管理Broker和TopicB.分配ConsumerGroupC.存储Producer和Consumer状态D.以上都是【答案】D【解析】ZooKeeper在Kafka中用于管理Broker和Topic、分配ConsumerGroup以及存储Producer和Consumer状态

5.Kafka中，Replica的概念是什么？（）A.一个分区的一个副本B.一个分区的所有副本C.一个Broker上的所有分区D.一个Broker上的所有副本【答案】A【解析】Replica是指一个分区的一个副本

6.Kafka中，哪些是ConsumerGroup的异常状态？（）A.ActiveB.InactiveC.ErrorD.Failed【答案】C【解析】ConsumerGroup的异常状态包括Error

7.Kafka中，哪些是Producer的acks参数的取值？（）A.0B.1C.-1D.以上都是【答案】D【解析】Producer的acks参数取值包括

0、1和-

18.Kafka中，哪些是Consumer的offset提交方式？（）A.自动提交B.手动提交C.以上都是D.以上都不是【答案】C【解析】Consumer的offset提交方式包括自动提交和手动提交

9.Kafka中，哪些是Topic的配置参数？（）A.relicationFactorB.partitionsC.maxBytesPerMessageD.以上都是【答案】D【解析】Topic的配置参数包括replicationFactor、partitions和maxBytesPerMessage

10.Kafka中，哪些是Broker的配置参数？（）A.hostB.portC.logDirD.以上都是【答案】D【解析】Broker的配置参数包括host、port和logDir

二、多选题（每题4分，共20分）

1.Kafka中，哪些是Producer的配置参数？（）A.brokerListB.batchSizeClingerSizeDlingerInterval【答案】B、C、D【解析】Producer的配置参数包括batchSize、clingerSize和lingerInterval

2.Kafka中，哪些是Consumer的配置参数？（）A.groupIdB.automaticallyCommitC.enableAutoCommitD.maxPollRecords【答案】A、B、C、D【解析】Consumer的配置参数包括groupId、automaticallyCommit、enableAutoCommit和maxPollRecords

3.Kafka中，哪些是Topic的副本状态？（）A.LeaderB.FollowerC.OfflineD.Inactive【答案】A、B、C【解析】Topic的副本状态包括Leader、Follower和Offline

4.Kafka中，哪些是ZooKeeper的配置参数？（）A.dataDirB.maxClientCnxnsC.tickTimeD.dataLogDir【答案】A、B、C【解析】ZooKeeper的配置参数包括dataDir、maxClientCnxns和tickTime

5.Kafka中，哪些是ConsumerGroup的分区分配策略？（）A.Round-robinB.StickyC.AvgD.Random【答案】A、B【解析】ConsumerGroup的分区分配策略包括Round-robin和Sticky

三、填空题（每题4分，共16分）

1.Kafka中，Producer发送消息的确认级别包括______、______和______【答案】无确认；确认收到Broker；确认收到副本

2.Kafka中，ConsumerGroup的异常状态包括______、______和______【答案】Error；Revoked；Lost

3.Kafka中，Topic的配置参数包括______、______和______【答案】replicationFactor；partitions；maxBytesPerMessage

4.Kafka中，Broker的配置参数包括______、______和______【答案】host；port；logDir

四、判断题（每题2分，共10分）

1.Kafka中，Producer发送消息的确认级别越高，性能越好（）【答案】（×）【解析】确认级别越高，性能越差

2.Kafka中，ConsumerGroup内的消费者共享订阅的Topic数据（）【答案】（√）

3.Kafka中，Topic的分区数量在创建后可以改变（）【答案】（×）【解析】Topic的分区数量在创建后只能增加不能减少

4.Kafka中，ZooKeeper用于管理Broker和Topic（）【答案】（√）

5.Kafka中，Consumer的offset提交方式包括自动提交和手动提交（）【答案】（√）

五、简答题（每题5分，共15分）

1.简述Kafka中Producer的acks参数的作用【答案】Producer的acks参数用于控制Producer发送消息的确认级别acks参数的取值包括

0、1和-1，分别表示Producer不需要Broker的任何确认、需要Broker确认收到消息但不等待所有副本写入、需要Broker等待所有副本写入后才认为消息发送成功

2.简述Kafka中ConsumerGroup的概念及其作用【答案】ConsumerGroup是指一组共享订阅Topic数据的消费者ConsumerGroup的作用是将订阅的Topic数据分摊到多个消费者上，实现负载均衡

3.简述Kafka中Topic的副本状态及其作用【答案】Topic的副本状态包括Leader、Follower和OfflineLeader副本负责处理所有读写请求，Follower副本从Leader副本复制数据，Offline副本表示副本不可用副本状态的作用是保证数据的可靠性和高可用性

六、分析题（每题10分，共20分）

1.分析Kafka中Consumer的自动提交offset的优缺点【答案】自动提交offset的优点是简单易用，缺点是可能导致数据丢失或重复处理自动提交offset的缺点在于无法精确控制offset的提交时机，可能会导致数据丢失或重复处理

2.分析Kafka中Producer的batchSize参数的作用及其对性能的影响【答案】Producer的batchSize参数用于控制Producer发送消息的批量大小batchSize参数的作用是减少网络请求的次数，提高发送性能batchSize参数对性能的影响是batchSize越大，发送性能越好，但会占用更多的内存

七、综合应用题（每题25分，共25分）

1.设计一个Kafka生产者消费者场景，包括Producer和Consumer的配置、Topic的创建以及消息的发送和接收【答案】Producer配置```javaPropertiesprops=newProperties;props.putbootstrap.servers,localhost:9092;props.putacks,all;props.putretries,0;props.putbatch.size,16384;props.putlinger.ms,1;props.putkey.serializer,org.apache.kafka.common.serialization.StringSerializer;props.putvalue.serializer,org.apache.kafka.common.serialization.StringSerializer;ProducerString,Stringproducer=newKafkaProducerprops;```Consumer配置```javaPropertiesprops=newProperties;props.putbootstrap.servers,localhost:9092;props.putgroup.id,test;props.putenable.auto.commit,false;props.putauto.commit.interval.ms,1000;props.putkey.deserializer,org.apache.kafka.common.serialization.StringDeserializer;props.putvalue.deserializer,org.apache.kafka.common.serialization.StringDeserializer;ConsumerString,Stringconsumer=newKafkaConsumerprops;consumer.subscribeCollections.singletonListtest-topic;```Topic创建```shellbin/kafka-topics.sh--create--topictest-topic--bootstrap-serverlocalhost:9092--partitions3--replication-factor2```消息发送```javaproducer.sendnewProducerRecordString,Stringtest-topic,key,value;producer.flush;```消息接收```javawhiletrue{ConsumerRecordsString,Stringrecords=consumer.poll100;forConsumerRecordString,Stringrecord:records{System.out.printfoffset=%d,key=%s,value=%s%n,record.offset,record.key,record.value;}consumer.commitSync;}```完整标准答案

一、单选题

1.B

2.B

3.D

4.D

5.A

6.C

7.D

8.C

9.D

10.D

二、多选题

1.B、C、D

2.A、B、C、D

3.A、B、C

4.A、B、C

5.A、B

三、填空题

1.无确认；确认收到Broker；确认收到副本

2.Error；Revoked；Lost

3.replicationFactor；partitions；maxBytesPerMessage

4.host；port；logDir

四、判断题

1.（×）

2.（√）

3.（×）

4.（√）

5.（√）

五、简答题

1.Producer的acks参数用于控制Producer发送消息的确认级别acks参数的取值包括

0、1和-1，分别表示Producer不需要Broker的任何确认、需要Broker确认收到消息但不等待所有副本写入、需要Broker等待所有副本写入后才认为消息发送成功

2.ConsumerGroup是指一组共享订阅Topic数据的消费者ConsumerGroup的作用是将订阅的Topic数据分摊到多个消费者上，实现负载均衡

3.Topic的副本状态包括Leader、Follower和OfflineLeader副本负责处理所有读写请求，Follower副本从Leader副本复制数据，Offline副本表示副本不可用副本状态的作用是保证数据的可靠性和高可用性

六、分析题

1.自动提交offset的优点是简单易用，缺点是可能导致数据丢失或重复处理自动提交offset的缺点在于无法精确控制offset的提交时机，可能会导致数据丢失或重复处理

2.Producer的batchSize参数用于控制Producer发送消息的批量大小batchSize参数的作用是减少网络请求的次数，提高发送性能batchSize参数对性能的影响是batchSize越大，发送性能越好，但会占用更多的内存

七、综合应用题

1.Producer配置```javaPropertiesprops=newProperties;props.putbootstrap.servers,localhost:9092;props.putacks,all;props.putretries,0;props.putbatch.size,16384;props.putlinger.ms,1;props.putkey.serializer,org.apache.kafka.common.serialization.StringSerializer;props.putvalue.serializer,org.apache.kafka.common.serialization.StringSerializer;ProducerString,Stringproducer=newKafkaProducerprops;```Consumer配置```javaPropertiesprops=newProperties;props.putbootstrap.servers,localhost:9092;props.putgroup.id,test;props.putenable.auto.commit,false;props.putauto.commit.interval.ms,1000;props.putkey.deserializer,org.apache.kafka.common.serialization.StringDeserializer;props.putvalue.deserializer,org.apache.kafka.common.serialization.StringDeserializer;ConsumerString,Stringconsumer=newKafkaConsumerprops;consumer.subscribeCollections.singletonListtest-topic;```Topic创建```shellbin/kafka-topics.sh--create--topictest-topic--bootstrap-serverlocalhost:9092--partitions3--replication-factor2```消息发送```javaproducer.sendnewProducerRecordString,Stringtest-topic,key,value;producer.flush;```消息接收```javawhiletrue{ConsumerRecordsString,Stringrecords=consumer.poll100;forConsumerRecordString,Stringrecord:records{System.out.printfoffset=%d,key=%s,value=%s%n,record.offset,record.key,record.value;}consumer.commitSync;}```。