网创优客建站品牌官网
为成都网站建设公司企业提供高品质网站建设
热线:028-86922220
成都专业网站建设公司

定制建站费用3500元

符合中小企业对网站设计、功能常规化式的企业展示型网站建设

成都品牌网站建设

品牌网站建设费用6000元

本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...

成都商城网站建设

商城网站建设费用8000元

商城网站建设因基本功能的需求不同费用上面也有很大的差别...

成都微信网站建设

手机微信网站建站3000元

手机微信网站开发、微信官网、微信商城网站...

建站知识

当前位置:首页 > 建站知识

windows下kafka的认证配置总结-创新互联

  1. config目录下创建kafka_server_jaas.conf文件:内容如下:

    成都创新互联公司是专业的陇县网站建设公司,陇县接单;提供网站建设、网站设计,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行陇县网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!

    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--zookeeperlocalhost:2181--replication-factor1--partitions1--topictest

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

另外有需要云服务器可以了解下创新互联cdcxhl.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


分享标题:windows下kafka的认证配置总结-创新互联
网站路径:http://bjjierui.cn/article/hpsji.html

其他资讯