?最近，在寫關(guān)于Kafka的消費(fèi)端代碼，發(fā)現(xiàn)若要消費(fèi)，需要登錄的時(shí)候，對對端Kafka服務(wù)進(jìn)行認(rèn)證，研究了一番，以下將代碼放出來

參考了文章

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

// 注意 kafka_client_jaas.conf 是認(rèn)證登錄配置文件，里面記錄使用了什么登錄方式和登錄賬號密碼
// 如果沒有這個(gè)文件，程序運(yùn)行的時(shí)候可能沒有任何提示并且無法消費(fèi)數(shù)據(jù)！
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");

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

//載入?yún)?shù)
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?模塊

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

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

如果使用了錯(cuò)誤模塊，運(yùn)行程序的時(shí)候可能沒有任何提示，并且不能消費(fèi)數(shù)據(jù)！