合肥做个网站什么价格便宜,中铁建设集团有限公司招标网,知名开发网站公司简介,国内ip地址代理免费背景
我们需要与第三方系统进行数据同步#xff0c;需要搭建公网Kafka#xff0c;Kafka默认是没有用户密码校验的#xff0c;所以我们需要配置用户名密码校验。
配置
新增JAAS配置文件
在conf目录下新增kafka_server_jaas.conf文件#xff0c;文件内容如下#xff1a;…背景
我们需要与第三方系统进行数据同步需要搭建公网KafkaKafka默认是没有用户密码校验的所以我们需要配置用户名密码校验。
配置
新增JAAS配置文件
在conf目录下新增kafka_server_jaas.conf文件文件内容如下
KafkaServer {org.apache.kafka.common.security.plain.PlainLoginModule requiredserviceNamekafkausernameadminpasswordadmin-secretuser_adminadmin-secretuser_alicealice-secret;
};修改kafka-server-start.sh脚本
-Djava.security.auth.login.configjaas配置文件的路径
export KAFKA_HEAP_OPTS-Xmx1G -Xms1G -Djava.security.auth.login.config/home/ubuntu/kafka_2.11-2.1.1/config/kafka_server_jaas.conf修改config/server.properties
这里配置了内网使用 PLAINTEXT 协议外网使用 SASL_PLAINTEXT 协议
listener.security.protocol.mapINTERNAL:PLAINTEXT,EXTERNAL:SASL_PLAINTEXTlistenersINTERNAL://10.0.12.3:9092,EXTERNAL://10.0.12.3:19092
advertised.listenersINTERNAL://10.0.12.3:9092,EXTERNAL://xx.xx.xx.xxx:19092
inter.broker.listener.nameINTERNAL
sasl.mechanism.inter.broker.protocolPLAIN
sasl.enabled.mechanismsPLAIN请将xx.xx.xx.xxx替换为你的公网IP
测试连接
用kafka tool测试连接下载地址https://www.kafkatool.com/
配置Zookeeper地址 配置Security 配置Bootstrap 配置用户名密码 此处的用户名密码需要和jaas的配置一致。
org.apache.kafka.common.security.plain.PlainLoginModule required
usernameadmin
passwordadmin-secret ;至此配置完成。
