windows下kafka的认证配置总结
admin
2023-03-15 00:41:09
0次
  1. 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";

    };

  2. 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. 在生产者的命令窗口随意输入, 回车发送信息, 在消费者窗口查看接收的消息

相关内容

热门资讯

空调连续工作多久需要停机休息 空调连续工作的时间取决于多个因素,包括空调的型号、功率、使用环境和维护情况等。一般来说,空调可以连续...
空调哪个符号是除湿的 空调除湿功能通常用一个水滴形状的符号表示。不同品牌和型号的空调遥控器可能会有所差异,但一般来说,除湿...
格力空调多长时间加一次氟利昂 1、一般情况下,空调对氟利昂的使用量是非常小的,所以在空调使用了四年左右的时候再考虑加也没问题。2、...
空调用多长时间需要加氟一次 一般情况下是五年。当出现以下这几种情况时,空调才需要加氟。1、空调的室内机和室外机各有两个接口,当接...
格调生活·C标思享荟:卡萨帝在... 9月12日的郑州龙湖金融岛,夜风轻拂,灯光璀璨。“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑...
品牌价值破千亿、高端份额持续领... 9月12日,“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑州站”在郑州龙湖金融岛举办。2026...
空调主板坏了修800还是换新的 空调主板坏了是修还是换新,需要考虑多个因素,以下是一些建议:1. 维修成本:如果维修费用较低,比如 ...
空调开多久需要休息多长时间 问题:空调开多久需要休息多长时间回答:1、在使用空调的过程中,一般空调开7~8个小时左右需要休息2~...
中央空调多长时间清洗一次 1、一般空调开机前清洗一次即可,空调开机中间时段再清洗一次,空调关机时清洗一次,这样比较合理。2、空...
中央空调氟利昂多久加一次 看空调制热和制冷程度,很多人的观点认为氟利昂必须一年放一次,其实这个观点是错误的,理解上面有点偏差,...