kafka?topic權限控制怎么設置

本篇內容介紹了“kafka topic權限控制怎么設置”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

Kafka是由Apache軟件基金會開發的一個開源流處理平臺，由Scala和Java編寫。Kafka是一種高吞吐量的分布式發布訂閱消息系統，它可以處理消費者在網站中的所有動作流數據。 這種動作（網頁瀏覽，搜索和其他用戶的行動）是在現代網絡上的許多社會功能的一個關鍵因素。 這些數據通常是由于吞吐量的要求而通過處理日志和日志聚合來解決。 對于像Hadoop一樣的日志數據和離線分析系統，但又要求實時處理的限制，這是一個可行的解決方案。Kafka的目的是通過Hadoop的并行加載機制來統一線上和離線的消息處理，也是為了通過集群來提供實時的消息。

下面看下kafka topic 權限控制的內容：

kafka官網

配置

設置權限

#查看權限
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 --list
#添加權限
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -add --allow-principal User:streaming --allow-host 10.10.151.* --producer --topic carbon_file_test
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -add --allow-principal User:streaming --allow-host 10.10.151.* --producer --topic eve_agg_file
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -add --allow-principal User:streaming --allow-host 10.10.151.* --producer --topic flink_test_producer
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -add --allow-principal User:streaming --allow-host 10.10.151.* --consumer --topic flink_test_producer
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -add --allow-principal User:streaming --allow-host 10.10.151.* --consumer --group=*  --topic flink_test_producer
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -add --allow-principal User:carbon --allow-host 10.10.151.* --consumer --group=*  --topic carbon_file_test
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -add --allow-principal User:carbon --allow-host 10.10.151.* --consumer --group=*  --topic eve_agg_file

刪除權限

./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -remove --allow-principal User:streaming --allow-host 10.10.151.* --producer --topic carbon_file_test --force
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -remove --allow-principal User:streaming --allow-host 10.10.151.* --producer --topic eve_agg_file --force
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -remove --allow-principal User:streaming --allow-host 10.10.151.* --producer --topic flink_test_producer --force
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -remove --allow-principal User:streaming --allow-host 10.10.151.* --consumer --topic flink_test_producer --force
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -remove --allow-principal User:streaming --allow-host 10.10.151.* --consumer --group=*  --topic flink_test_producer --force
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -remove --allow-principal User:carbon --allow-host 10.10.151.* --consumer --group=*  --topic carbon_file_test --force
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 -remove --allow-principal User:carbon --allow-host 10.10.151.* --consumer --group=*  --topic eve_agg_file --force

命令參數

“kafka topic權限控制怎么設置”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！