windows下kafka的認(rèn)證配置總結(jié)-創(chuàng)新互聯(lián)
config目錄下創(chuàng)建kafka_server_jaas.conf文件：內(nèi)容如下：
成都創(chuàng)新互聯(lián)公司是專業(yè)的隴縣網(wǎng)站建設(shè)公司，隴縣接單;提供網(wǎng)站建設(shè)、網(wǎng)站設(shè)計(jì),網(wǎng)頁設(shè)計(jì),網(wǎng)站設(shè)計(jì),建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行隴縣網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴(kuò)展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團(tuán)隊(duì),希望更多企業(yè)前來合作!
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-secret"
user_admin="admin-secret"
user_alice="alice-secret";
};
config目錄下創(chuàng)建kafka_client_jaas.conf文件：內(nèi)容如下：
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="alice"
password="alice-secret";
};
3. 修改config目錄下的server.properties文件：
修改內(nèi)容：自定義log.dirs（從新定義日志文件）
log.dirs=D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/kafka-logs
添加內(nèi)容：
#advertised.listeners=PLAINTEXT://192.168.66.119:9092
listeners=SASL_PLAINTEXT://localhost:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
#配置這個(gè)會報(bào)org.apache.kafka.common.errors.GroupAuthorizationException: Not authorized to access group:這個(gè)是授權(quán)配置的
#authorizer.class.name = kafka.security.auth.SimpleAclAuthorizer
allow.everyone.if.no.acl.found=false
4. config目錄下的consumer.properties和producer.properties添加如下內(nèi)容：
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
5. \bin\windows目錄下的kafka-server-start.bat文件添加內(nèi)容如下：
set KAFKA_OPTS=-Djava.security.auth.login.config=D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/config/kafka_server_jaas.conf
6. \bin\windows目錄下的kafka-console-producer.bat和kafka-console-consumer.bat文件添加內(nèi)容如下：
set KAFKA_OPTS=-Djava.security.auth.login.config=D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/config/kafka_client_jaas.conf
-------------------- 基本的配置已經(jīng)完成, 現(xiàn)在開始逐個(gè)啟動----------------------------------
7. 啟動kafka自帶的zookeeper：
在\bin\windows目錄下：shit+右鍵：彈出框后點(diǎn)擊（在此處打開命令窗口）, 輸入命令：zkserver
8. 啟動kafka
在kafka根目錄下：shit+右鍵：彈出框后點(diǎn)擊（在此處打開命令窗口）, 輸入命令：
.\bin\windows\kafka-server-start.bat .\config\server.properties9. 創(chuàng)建主題：
在\bin\windows目錄下：shit+右鍵：彈出框后點(diǎn)擊（在此處打開命令窗口）, 輸入命令：
kafka-topics.bat--create--zookeeperlocalhost:2181--replication-factor1--partitions1--topictest
10. 創(chuàng)建一個(gè)生產(chǎn)者：
在\bin\windows目錄下：shit+右鍵：彈出框后點(diǎn)擊（在此處打開命令窗口）, 輸入命令：
kafka-console-producer.bat --broker-list localhost:9092 --topic test --producer.config D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/config/producer.properties
11. 創(chuàng)建一個(gè)消費(fèi)者：
在\bin\windows目錄下：shit+右鍵：彈出框后點(diǎn)擊（在此處打開命令窗口）, 輸入命令：
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning --consumer.config D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/config/consumer.properties
12. 在生產(chǎn)者的命令窗口隨意輸入， 回車發(fā)送信息， 在消費(fèi)者窗口查看接收的消息
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
文章名稱：windows下kafka的認(rèn)證配置總結(jié)-創(chuàng)新互聯(lián)
轉(zhuǎn)載來于：http://www.jiaotiyi.com/article/hpsji.html