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

相关内容

热门资讯

中国发布禁令,禁止美国制裁中国... 2026年4月24日美国发布公告,把中国5家石化企业列入制裁名单,理由是参与或协助伊朗的石油交易,引...
电力系统母线安全保护领域取得关... (来源:中国电力新闻网) 转自:中国电力新闻网 近日,山西铝业自主研发的《弧光保护系统安装优化方法、...
第三届“探索雅安·阅见美好”阅... 近日,由雅安市图书馆主办的第三届“探索雅安·阅见美好”阅读打卡活动在市区三雅园及雅安市图书馆开展。 ...
实验型真空冷冻干燥机选型指南:... 导语:实验型真空冷冻干燥机作为科研、高校及企业研发环节的关键设备,其性能稳定性直接影响物料干燥效率与...
丁薛祥调研华为芯片基础技术研究... 5月8日晚,中央电视台《新闻联播》播出了一则重量级画面:中共中央政治局常委、国务院副总理丁薛祥到访华...
王自如公布智能指环项目 售价或... 【CNMO科技消息】5月9日,据CNMO科技了解,王自如近日通过视频展示其研发的智能指环产品,该产品...
“190元榴莲遭仅退款”商家直... 近日,河南濮阳一销售冷冻榴莲果肉商家在网络平台发视频称,自家生意遭遇买家恶意“仅退款”。虽然售卖榴莲...
一名中国公民被印度边防部队拘捕... 近日,一名在尼泊尔的中国公民在尼泊尔、印度边境地区因误入印境内被印边防部队拘捕。驻加尔各答总领馆再次...
凤凰直击东盟峰会:菲方推海事中... 5月8日,第48届东盟峰会落幕。菲律宾提出设立“东盟海事中心”的倡议,成为本届峰会焦点之一。菲律宾总...
快30岁,还不像个大人,我们怎... 2025年,邓鹭下定决心裸辞。此后长达一年的gap时间里,她频繁觉得自己像漂在海上,且不知靠岸何处。...