?最近，在寫關于Kafka的消費端代碼，發現若要消費，需要登錄的時候，對對端Kafka服務進行認證，研究了一番，以下將代碼放出來

參考了文章

Kafka配置安全認證_月下茶涼的博客-CSDN博客_kafka安全認證Kafka配置安全認證提示：本人提示：寫完文章后，目錄可以自動生成，如何生成可參考右邊的幫助文檔文章目錄系列文章目錄前言一、pandas是什么？二、使用步驟1.引入庫2.讀入數據總結前言提示：這里可以添加本文要記錄的大概內容：例如：隨著人工智能的不斷發展，機器學習這門技術也越來越重要，很多人都開啟了學習機器學習，本文就介紹了機器學習的基礎內容。提示：以下是本篇文章正文內容，下面案例可供參考一、pandas是什么？示例：pan..https://blog.csdn.net/qq_42057890/article/details/117564848java?登錄代碼

// 注意 kafka_client_jaas.conf 是認證登錄配置文件，里面記錄使用了什么登錄方式和登錄賬號密碼
// 如果沒有這個文件，程序運行的時候可能沒有任何提示并且無法消費數據！
System.setProperty("java.security.auth.login.config","kafka_client_jaas.conf");        

Properties props = new Properties();
props.put("bootstrap.servers", "xxx.xxx.xxx.xxx");
props.put("group.id", UUID.randomUUID().toString());
props.put("enable.auto.commit", "true");
props.put("auto.commit.interval.ms", "1000");
props.put("key.deserializer", StringDeserializer.class.getName());
props.put("value.deserializer", StringDeserializer.class.getName());
props.put("auto.offset.reset","earliest");

//加密傳輸協議
props.put("security.protocol","SASL_PLAINTEXT");
//加密方式
props.put("sasl.mechanism","SCRAM-SHA-256");

//載入參數
KafkaConsumer kafkaConsumer = new KafkaConsumer(props);

kafka_client_jaas.conf?文件配置

KafkaClient {
 	org.apache.kafka.common.security.plain.PlainLoginModule required
	username="XXXX"
	password="XXXX";
};

注意！

這里演示的是使用了

org.apache.kafka.common.security.plain.PlainLoginModule?模塊

也有可能會使用其他模塊，例如我項目需要用到

org.apache.kafka.common.security.scram.ScramLoginModule

如果使用了錯誤模塊，運行程序的時候可能沒有任何提示，并且不能消費數據！