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

相关内容

热门资讯

法院回应LV起诉地产开发商 7月26日,厦门市湖里区人民法院发布情况通报,网传案情“路易威登公司起诉地产开发商,因楼盘外立面四叶...
携程的问题不仅在于垄断,更在于... 国内平台科技企业一般都是通过向B端收费、抽佣获利,尽量给消费者创造一个比较清爽的使用环境。携程算是最...
海信电视用遥控器关闭后打不开 原因可能是遥控器的电池没有装好或者是没电了,需要重新安装一下电池或者更换新的电池试一试;原因可能是电...
电视机突然没电源打不开了 有可能是电视开关的电源线断了;可能是电视在使用时短路;可能是电源插头插座松动;可能是电视内部零件接触...
电热水器下面那个小龙头漏水是怎... 电热水器下面那个小龙头漏水是怎么回事?1、因为安全阀发生了故障或者是已经被损坏了,就会有漏水的现象;...
回答下电脑桌面一片空白怎么恢复 电脑桌面上如果是一片空白,那说明您的电脑图标被隐藏了,想要恢复就要按照如下的三个步骤去操作才行。 第...
澳总理要找特朗普“理论”关税:... 当地时间7月26日,澳大利亚总理阿尔巴尼斯表示,他将直接向美国总统特朗普提出抗议,反对美国新近宣布的...
正颌手术反成“鞋拔子脸”,医生... 为改善轻微地包天做正颌手术,没想到反成“鞋拔子脸”。据第一现场报道,24岁女孩小雨在接受采访时表示,...
在泰国GMM书展活动中遭锁喉、... 7月25日,一名中国女粉丝在泰国曼谷GMM书展活动中遭工作人员锁喉、抱摔等暴力对待。当事人称随后前往...
中国驻菲律宾大使:过去半年,我... 近日,中国驻菲律宾大使井泉接受看看新闻Knews独家采访,直面仁爱礁、黄岩岛海上争端、中菲关系走向、...