windows下kafka的认证配置总结

ndlli

• 　　config目录下创建kafka_server_jaas.conf文件：内容如下：
  　　KafkaServer {
  　　org.apache.kafka.common.security.plain.PlainLoginModule required
  　　username="admin"
  　　password="admin-secret"
  　　user_admin="admin-secret"
  　　user_alice="alice-secret";
  　　};
  
• 　　config目录下创建kafka_client_jaas.conf文件：内容如下：
  

　　KafkaClient {
　　org.apache.kafka.common.security.plain.PlainLoginModule required
　　username="alice"
　　password="alice-secret";
　　};
　　3. 修改config目录下的server.properties文件：
　　修改内容：自定义log.dirs（从新定义日志文件）
　　log.dirs=D:/kafka_2.10-0.9.0.0/kafka_2.10-0.10.1.0/kafka-logs
　　添加内容：
　　#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
　　#配置这个会报org.apache.kafka.common.errors.GroupAuthorizationException: Not authorized to access group:这个是授权配置的
　　#authorizer.class.name = kafka.security.auth.SimpleAclAuthorizer
　　allow.everyone.if.no.acl.found=false
　　4. config目录下的consumer.properties和producer.properties添加如下内容：
　　security.protocol=SASL_PLAINTEXT
　　sasl.mechanism=PLAIN
　　5. \bin\windows目录下的kafka-server-start.bat文件添加内容如下：
　　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文件添加内容如下：
　　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
　　-------------------- 基本的配置已经完成, 现在开始逐个启动----------------------------------
　　7. 启动kafka自带的zookeeper：
　　在\bin\windows目录下：shit+右键：弹出框后点击（在此处打开命令窗口）, 输入命令：zkserver
　　8. 启动kafka
　　在kafka根目录下：shit+右键：弹出框后点击（在此处打开命令窗口）, 输入命令：
.\bin\windows\kafka-server-start.bat .\config\server.properties　　9. 创建主题：
　　在\bin\windows目录下：shit+右键：弹出框后点击（在此处打开命令窗口）, 输入命令：
　　kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
　　10. 创建一个生产者：
　　在\bin\windows目录下：shit+右键：弹出框后点击（在此处打开命令窗口）, 输入命令：
　　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. 创建一个消费者：
　　在\bin\windows目录下：shit+右键：弹出框后点击（在此处打开命令窗口）, 输入命令：
　　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. 在生产者的命令窗口随意输入， 回车发送信息， 在消费者窗口查看接收的消息