三门网站制作,峡江网站建设,短链接生成网址,asp.net网站开发试题背景#xff1a;之前资产信息用网络接口进行数据推送#xff0c;但是接口推送需要验证而且反应较慢。Kafak中间件提供了另一种可行的数据推送方式#xff0c;它可以进行消息队列推送#xff0c;且反应速度快。但是Kafka需部署在公网环境#xff0c;并进行登录验证#xf…背景之前资产信息用网络接口进行数据推送但是接口推送需要验证而且反应较慢。Kafak中间件提供了另一种可行的数据推送方式它可以进行消息队列推送且反应速度快。但是Kafka需部署在公网环境并进行登录验证如果部署Kafka后未设置登录验证会被恶意扫描到此时向Kafka里面push超过1G的文件将会直接导致Kafka宕掉。 为了避免Kafka宕掉建设在使用Kafka过程中配置登录验证以下是Kafka登录验证的配置过程。 1、修改kafka配置文件 vim /asop/kafka/kafka_2.11-2.1.0/config/server.properties broker.id0 listenersSASL_PLAINTEXT://:9092 advertised.listenersSASL_PLAINTEXT://1.1.1.1:9092 num.network.threads3 num.io.threads8 socket.send.buffer.bytes102400 socket.receive.buffer.bytes102400 socket.request.max.bytes104857600 log.dirs/asop/kafka/logs num.partitions1 num.recovery.threads.per.data.dir1 offsets.topic.replication.factor1 transaction.state.log.replication.factor1 transaction.state.log.min.isr1 log.retention.hours168 log.segment.bytes1073741824 log.retention.check.interval.ms300000 zookeeper.connectlocalhost:2181 zookeeper.connection.timeout.ms6000 group.initial.rebalance.delay.ms0 #使用的认证协议 security.inter.broker.protocolSASL_PLAINTEXT #SASL机制 sasl.enabled.mechanismsPLAIN sasl.mechanism.inter.broker.protocolPLAIN #完成身份验证的类 authorizer.class.namekafka.security.auth.SimpleAclAuthorizer #如果没有找到ACL访问控制列表配置则允许任何操作。 allow.everyone.if.no.acl.foundfalse #需要开启设置超级管理员,设置visitor用户为超级管理员 super.usersUser:visitor 2、为server创建登录验证文件可以自主命名文件 如vim /asop/kafka/kafka_2.11-2.1.0/config/kafka_server_jaas.conf 文件内容如下 KafkaServer { org.apache.kafka.common.security.plain.PlainLoginModule required username“visitor” password“qaz123” user_visitor“qaz123”; }; 3、修改kafka安装目录 vim /asop/kafka/kafka_2.11-2.1.0/bin/kafka-server-start.sh在文件最上面添加变量 export KAFKA_OPTS -Djava.security.auth.login.config/asop/kafka/kafka_2.11-2.1.0/config/kafka_server_jaas.conf 4、为consumer和producer创建登录验证文件可自主命名文件 如kafka_client_jaas.conf文件内容如下如果是程序访问如springboot访问可以不配置 vim /asop/kafka/kafka_2.11-2.1.0/config/kafka_client_jaas.conf KafkaClient { org.apache.kafka.common.security.plain.PlainLoginModule required username“visitor” password“qaz123”; }; 5、在consumer.properties和producer.properties里分别加上如下配置 vim /asop/kafka/kafka_2.11-2.1.0/config/consumer.properties vim /asop/kafka/kafka_2.11-2.1.0/config/producer.properties security.protocolSASL_PLAINTEXT sasl.mechanismPLAIN 6、修改kafka安装目录bin/kafka-console-producer.sh和bin/kafka-console-consumer.sh 在文件最上面添加变量 vim /asop/kafka/kafka_2.11-2.1.0/bin/kafka-console-producer.sh export KAFKA_OPTS -Djava.security.auth.login.config/asop/kafka/kafka_2.11-2.1.0/config/kafka_client_jaas.conf 7、分别启动zookeeper和kafka至此服务端kafka用户登录验证配置完成先关闭kafka后关闭zookeeper 关闭服务kafka /asop/kafka/kafka_2.11-2.1.0/bin/kafka-server-stop.sh -daemon /asop/kafka/kafka_2.11-2.1.0/config/server.properties 关闭服务zookeeper-3.4.13 /asop/zk/zookeeper-3.4.13/bin/zkServer.sh stop /asop/zk/zookeeper-3.4.13/conf/zoo.cfg 启动服务zookeeper-3.4.13 /asop/zk/zookeeper-3.4.13/bin/zkServer.sh start /asop/zk/zookeeper-3.4.13/conf/zoo.cfg 启动服务kafka #/asop/kafka/kafka_2.11-2.1.0/bin/kafka-server-start.sh -daemon /asop/kafka/kafka_2.11-2.1.0/config/server.properties 8、创建及查看主题 /asop/kafka/kafka_2.11-2.1.0/bin/kafka-console-producer.sh --broker-list 1.1.1.1:9092 --topic cmdb --producer-property security.protocolSASL_PLAINTEXT --producer-property sasl.mechanismPLAIN 接收消息 /asop/kafka/kafka_2.11-2.1.0/bin/kafka-console-consumer.sh --bootstrap-server 1.1.1.1:9092 --topic cmdb --from-beginning --consumer-property security.protocolSASL_PLAINTEXT --consumer-property sasl.mechanismPLAIN 以上就是本期的全部内容。大家好我是乐乐专注IT运维技术研究与分享更多运维知识请关注乐维社区如有运维问题也欢迎到社区提问