作者：恩慈

一、部署kafka-KB包

1．上传软件包

依次点击 部署中心----部署组件----上传软件包
选择需要升级的kafka版本并点击确定

2．部署kafka

依次点击部署中心----部署组件----物理/虚拟机部署----选择集群----下一步

选择手动部署----选择需要部署的版本----下一步

等待部署完成，完成后查看服务状态

3．配置kafka

各配置文件及内容如下：

/opt/dtstack/Kafka/kafka/bin/kafka-server-start.sh

/opt/dtstack/Kafka/kafka/bin/kafka-topics.sh

/opt/dtstack/Kafka/kafka/config/kafka_server_jaas.conf

/opt/dtstack/Kafka/kafka/config/server.properties

/opt/dtstack/Kafka/kafka/config/client_jaas.conf

/opt/dtstack/Kafka/kafka/config/client.properties

/opt/dtstack/Kafka/kafka/config/consumer.properties

/opt/dtstack/Kafka/kafka/config/producer.properties

二、测试kerberos

1．未认证测试

（1）创建topic

（2）查询topic

（3）删除topic

（4）生产topic

（5）消费topic

2．认证后测试

（1）创建topic

（2）查询topic

（3）生产数据

（4）消费数据

（5）删除topic

三、测试ACL

1．未赋权

无法生产

无法消费

2．赋权后

kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add
–allow-principal User:enci --operation Read --operation Write --topic enci01

可以消费

可以生产

更多技术信息请查看云掣官网https://yunche.pro/?t=yrgw