2026年Kafka工程師面試題及答案一、單選題（共10題，每題2分）1.Kafka中，Producer發(fā)送消息時，以下哪種分區(qū)策略會為每條消息分配一個唯一的分區(qū)？A.Range分區(qū)B.Sticky分區(qū)C.Round-robin分區(qū)D.Random分區(qū)2.Kafka中，Topic的副本因子設(shè)置為3，集群中有5個Broker，那么最多可以有多少個ISR？A.3B.4C.5D.63.Kafka中，以下哪個參數(shù)控制Producer發(fā)送消息的超時時間？A.`replica.lag.time.max.ms`B.`request.timeout.ms`C.`fetch.min.bytes`D.`max.in.flight.requests.per.connection`4.Kafka中，Consumer的`group.id`設(shè)置為空，這種模式下Consumer屬于哪種類型？A.指定組ConsumerB.消息組ConsumerC.獨立ConsumerD.命名Consumer5.Kafka中，以下哪種機制用于保證消息的至少一次傳遞？A.事務(wù)性消息B.確認機制C.重試策略D.端到端一致性6.Kafka中，Broker掛掉時，哪些副本會變?yōu)镮SR？A.所有Leader副本B.Leader副本和Follower副本C.只有Leader副本D.只有Follower副本7.Kafka中，以下哪種分區(qū)策略會根據(jù)Key的哈希值將消息分配到不同的分區(qū)？A.Range分區(qū)B.Sticky分區(qū)C.Round-robin分區(qū)D.Consistent哈希分區(qū)8.Kafka中，Consumer的`mit`設(shè)置為true時，自動提交偏移量的時間間隔由哪個參數(shù)控制？A.`erval.ms`B.`fetch.max.wait.ms`C.`erval.ms`D.`fetch.min.bytes`9.Kafka中，以下哪種狀態(tài)表示Topic的副本正在同步數(shù)據(jù)？A.LEADINGB.FOLLOWINGC.ISRAILINGD.IN_SYNC10.Kafka中，Producer發(fā)送消息時，以下哪種編碼方式會為消息添加魔法字節(jié)？A.JSONB.AvroC.ProtobufD.Binary二、多選題（共5題，每題3分）1.Kafka中，哪些參數(shù)會影響消息的拉取性能？A.`fetch.max.wait.ms`B.`fetch.min.bytes`C.`max.poll.records`D.`fetch.request.max.bytes`E.`replica.lag.time.max.ms`2.Kafka中，哪些操作會觸發(fā)ZooKeeper的寫操作？A.創(chuàng)建TopicB.修改副本配置C.添加BrokerD.刪除TopicE.拉取消息3.Kafka中，哪些場景下建議使用事務(wù)性消息？A.跨服務(wù)消息傳遞B.數(shù)據(jù)庫操作C.高可用架構(gòu)D.實時數(shù)據(jù)處理E.消息堆積處理4.Kafka中，哪些參數(shù)可以配置Consumer的消費者組行為？A.`fetch.max.wait.ms`B.`mit`C.`erval.ms`D.`session.timeout.ms`E.`erval.ms`5.Kafka中，哪些操作會導(dǎo)致ISR變化？A.Broker宕機B.副本同步完成C.副本選舉D.Topic刪除E.消息提交三、簡答題（共5題，每題5分）1.簡述Kafka中ISR的概念及其作用。2.簡述Kafka中Producer的四種發(fā)送消息模式。3.簡述Kafka中Consumer的兩種消費模式。4.簡述Kafka中Topic的分區(qū)策略及其優(yōu)缺點。5.簡述Kafka中消息的順序保證機制。四、論述題（共2題，每題10分）1.詳細說明Kafka如何保證消息的順序性，并分析其適用場景和限制。2.詳細說明Kafka的消費者組機制，包括組內(nèi)消息分配、會話超時處理、故障恢復(fù)等。五、編程題（共2題，每題10分）1.編寫一段KafkaProducer的代碼，實現(xiàn)發(fā)送JSON格式的消息到指定Topic，并設(shè)置重試策略。2.編寫一段KafkaConsumer的代碼，實現(xiàn)從指定Topic消費消息，并展示消息內(nèi)容。答案及解析一、單選題答案及解析1.CRange分區(qū)會根據(jù)消息Key的順序?qū)⑾⒎峙涞讲煌姆謪^(qū)，確保相同Key的消息被分配到同一個分區(qū)。2.AISR（In-SyncReplicas）是指與Leader副本保持同步的Follower副本集合。副本因子為3時，最多可以有3個ISR。3.B`request.timeout.ms`控制Producer發(fā)送請求的超時時間，用于保證消息發(fā)送的可靠性。4.C當(dāng)Consumer的`group.id`為空時，該Consumer為獨立Consumer，消息會被投遞到該Consumer，不會與其他Consumer共享消息。5.C重試策略可以保證在發(fā)送失敗時重新發(fā)送消息，從而實現(xiàn)至少一次傳遞。事務(wù)性消息和確認機制更多用于保證消息的可靠傳遞。6.A當(dāng)Broker掛掉時，其上的所有Leader副本都會變?yōu)镮SR，因為它們無法再作為Leader。7.DConsistent哈希分區(qū)會根據(jù)Key的哈希值將消息分配到不同的分區(qū)，確保相同Key的消息被分配到同一個分區(qū)。8.A`erval.ms`控制Consumer自動提交偏移量的時間間隔。9.DIN_SYNC表示副本正在同步數(shù)據(jù)，但可能尚未達到完全同步狀態(tài)。10.DBinary編碼方式會為消息添加魔法字節(jié)，用于區(qū)分不同的編碼格式。二、多選題答案及解析1.A,B,C,D這些參數(shù)都會影響消息的拉取性能，`fetch.max.wait.ms`控制等待更多消息的時間，`fetch.min.bytes`控制最小拉取字節(jié)數(shù)，`max.poll.records`控制每次拉取的最大消息數(shù)，`fetch.request.max.bytes`控制每次拉取請求的最大字節(jié)數(shù)。2.A,B,C,D創(chuàng)建Topic、修改副本配置、添加Broker、刪除Topic都需要寫入ZooKeeper，而拉取消息是讀操作。3.A,B,C,D事務(wù)性消息適用于跨服務(wù)消息傳遞、數(shù)據(jù)庫操作、高可用架構(gòu)和實時數(shù)據(jù)處理場景，不適用于消息堆積處理。4.B,C,D,E`mit`控制是否自動提交偏移量，`erval.ms`控制自動提交的時間間隔，`session.timeout.ms`控制會話超時時間，`erval.ms`控制最大拉取間隔時間。5.A,B,CBroker宕機會導(dǎo)致ISR變化，副本同步完成也會影響ISR狀態(tài)，副本選舉可能改變ISR成員，但Topic刪除不會影響ISR。三、簡答題答案及解析1.ISR的概念及其作用ISR（In-SyncReplicas）是指與Leader副本保持同步的Follower副本集合。其作用是保證數(shù)據(jù)的高可用性和可靠性，當(dāng)Leader副本掛掉時，可以從ISR中選擇一個新的Leader繼續(xù)提供服務(wù)。2.Producer的四種發(fā)送消息模式-同步發(fā)送：等待Broker確認返回，保證消息發(fā)送成功-異步發(fā)送：發(fā)送消息后立即返回，通過回調(diào)處理結(jié)果-單向發(fā)送：發(fā)送消息后不等待確認，適用于不需要保證可靠性的場景-端到端發(fā)送：結(jié)合事務(wù)性消息，保證消息的可靠傳遞3.Consumer的兩種消費模式-指定組消費：Consumer屬于某個組，消息會根據(jù)分區(qū)分配給組內(nèi)Consumer，實現(xiàn)消息的負載均衡-獨立消費：Consumer不屬于任何組，消息會直接投遞到該Consumer4.Topic的分區(qū)策略及其優(yōu)缺點-Range分區(qū)：根據(jù)Key的順序分配消息，優(yōu)點是實現(xiàn)范圍查詢方便，缺點是可能導(dǎo)致數(shù)據(jù)傾斜-Sticky分區(qū)：將相同Key的消息分配到同一個分區(qū)，優(yōu)點是保證消息順序，缺點是分區(qū)數(shù)量固定-Round-robin分區(qū)：按順序分配消息到不同分區(qū)，優(yōu)點是簡單高效，缺點是可能導(dǎo)致數(shù)據(jù)傾斜-Consistent哈希分區(qū)：根據(jù)Key的哈希值分配消息，優(yōu)點是均勻分布數(shù)據(jù)，缺點是擴容時可能導(dǎo)致數(shù)據(jù)遷移5.消息的順序保證機制Kafka通過以下機制保證消息的順序性：-在Producer端設(shè)置消息的Key-使用相同的Key發(fā)送消息-確保消息被分配到同一個分區(qū)-確保Consumer屬于同一個組順序保證僅限于同一個分區(qū)內(nèi)的消息四、論述題答案及解析1.Kafka如何保證消息的順序性及其適用場景和限制Kafka保證消息順序性的機制：-Producer端設(shè)置消息Key，確保相同Key的消息被分配到同一個分區(qū)-Consumer端使用相同的Key消費消息適用場景：-需要保證消息順序的業(yè)務(wù)場景，如訂單處理、支付流水等限制：-僅限于同一個分區(qū)內(nèi)的消息-分區(qū)數(shù)量有限制-高并發(fā)場景下可能導(dǎo)致數(shù)據(jù)傾斜2.Kafka的消費者組機制消費者組機制包括：-組內(nèi)消息分配：消息會根據(jù)分區(qū)和組內(nèi)Consumer數(shù)量進行負載均衡-會話超時處理：Consumer長時間未與Broker通信會被視為失效，其分區(qū)會被重新分配-故障恢復(fù)：Consumer宕機后，其分區(qū)會被重新分配給其他Consumer-消息重復(fù)處理：需要通過冪等性和事務(wù)性消息保證消息只被處理一次五、編程題答案及解析1.KafkaProducer代碼javaimportducer.KafkaProducer;importducer.ProducerConfig;importducer.ProducerRecord;importmon.serialization.StringSerializer;importjava.util.Properties;publicclassKafkaProducerExample{publicstaticvoidmain(String[]args){Propertiesprops=newProperties();props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,StringSerializer.class.getName());props.put(ProducerConfig.RETRIES_CONFIG,3);props.put(ProducerConfig.RETRY_BACKOFF_MS_CONFIG,3000);props.put(ProducerConfig.MAX_BLOCK_MS_CONFIG,10000);KafkaProducer<String,String>producer=newKafkaProducer<>(props);Stringtopic="test-topic";Stringkey="key1";Stringvalue="{\"name\":\"John\",\"age\":30}";ProducerRecord<String,String>record=newProducerRecord<>(topic,key,value);producer.send(record);producer.close();}}2.KafkaConsumer代碼javaimportorg.apache.kafka.clients.consumer.ConsumerConfig;importorg.apache.kafka.clients.consumer.KafkaConsumer;importorg.apache.kafka.clients.consumer.ConsumerRecords;importorg.apache.kafka.clients.consumer.OffsetAndMetadata;importmon.serialization.StringDeserializer;importjava.time.Duration;importjava.util.Collections;importjava.util.Properties;publicclassKafkaConsumerExample{publicstaticvoidmain(String[]args){Propertiesprops=newProperties();props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");props.put(ConsumerConfig.GROUP_ID_CONFIG,"test-group");props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,StringDeserializer.class.getName());props.put(ConsumerConfig.VALUE_DESERIALIZER_CL