欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

kafka topic 權(quán)限控制(設(shè)置刪除權(quán)限)

 更新時(shí)間:2021年11月26日 15:28:42   作者:jzy3711  
大家都知道Kafka是一個(gè)消息隊(duì)列,把消息放到隊(duì)列里邊的叫生產(chǎn)者,從隊(duì)列里邊消費(fèi)的叫消費(fèi)者。今天通過(guò)本文給大家介紹kafka topic 權(quán)限控制的相關(guān)知識(shí),感興趣的朋友一起看看吧

Kafka是由Apache軟件基金會(huì)開(kāi)發(fā)的一個(gè)開(kāi)源流處理平臺(tái),由Scala和Java編寫。Kafka是一種高吞吐量的分布式發(fā)布訂閱消息系統(tǒng),它可以處理消費(fèi)者在網(wǎng)站中的所有動(dòng)作流數(shù)據(jù)。 這種動(dòng)作(網(wǎng)頁(yè)瀏覽,搜索和其他用戶的行動(dòng))是在現(xiàn)代網(wǎng)絡(luò)上的許多社會(huì)功能的一個(gè)關(guān)鍵因素。 這些數(shù)據(jù)通常是由于吞吐量的要求而通過(guò)處理日志和日志聚合來(lái)解決。 對(duì)于像Hadoop一樣的日志數(shù)據(jù)和離線分析系統(tǒng),但又要求實(shí)時(shí)處理的限制,這是一個(gè)可行的解決方案。Kafka的目的是通過(guò)Hadoop的并行加載機(jī)制來(lái)統(tǒng)一線上和離線的消息處理,也是為了通過(guò)集群來(lái)提供實(shí)時(shí)的消息。

下面看下kafka topic 權(quán)限控制的內(nèi)容:

kafka官網(wǎng)

配置

authorizer.class.name= kafka.security.auth.SimpleAclAuthorizer
allow.everyone.if.no.acl.found=true;super.users=User:admin;User:streaming;User:carbon;User:flink

設(shè)置權(quán)限

#查看權(quán)限
./kafka-acls.sh --authorizer-properties zookeeper.connect=test01:2181,test02:2181,test03:2181 --list
#添加權(quán)限
./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

刪除權(quán)限

./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

命令參數(shù)

到此這篇關(guān)于kafka topic 權(quán)限控制(設(shè)置刪除權(quán)限)的文章就介紹到這了,更多相關(guān)kafka topic 權(quán)限內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • java響應(yīng)式編程之Reactor使用示例解析

    java響應(yīng)式編程之Reactor使用示例解析

    這篇文章主要為大家介紹了java響應(yīng)式編程之Reactor使用示例解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-07-07
  • Java多線程的同步優(yōu)化的6種方案

    Java多線程的同步優(yōu)化的6種方案

    大家使用多線程無(wú)非是為了提高性能,在Java中,有多線程并發(fā)時(shí),我們可以使用多線程同步的方式來(lái)解決內(nèi)存一致性的問(wèn)題。本文就詳細(xì)的介紹了Java多線程同步優(yōu)化,感興趣的可以了解一下
    2021-05-05
  • 深入理解Java中的注解Annotation

    深入理解Java中的注解Annotation

    這篇文章主要介紹了深入理解Java中的注解Annotation,注解在Java中確實(shí)也很常見(jiàn),但是人們常常不會(huì)自己定義一個(gè)注解拿來(lái)用,我們雖然很少去自定義注解,但是學(xué)會(huì)注解的寫法,注解的定義,學(xué)會(huì)利用反射解析注解中的信息,在開(kāi)發(fā)中能夠使用到,這是很關(guān)鍵的,需要的朋友可以參考下
    2023-10-10
  • JavaEE線程安全實(shí)現(xiàn)線程池方法

    JavaEE線程安全實(shí)現(xiàn)線程池方法

    這篇文章主要介紹了JavaEE線程安全實(shí)現(xiàn)線程池方法,文章圍繞主題展開(kāi)詳細(xì)的內(nèi)容介紹,具有一定的參考價(jià)值,需要的小伙伴可以參考一下
    2022-06-06
  • 基于java ssm springboot實(shí)現(xiàn)選課推薦交流平臺(tái)系統(tǒng)

    基于java ssm springboot實(shí)現(xiàn)選課推薦交流平臺(tái)系統(tǒng)

    這篇文章主要介紹了選課推薦交流平臺(tái)系統(tǒng)是基于java ssm springboot來(lái)的實(shí)現(xiàn)的,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2021-08-08
  • java讀取圖片并轉(zhuǎn)化為二進(jìn)制字符串的實(shí)現(xiàn)方法

    java讀取圖片并轉(zhuǎn)化為二進(jìn)制字符串的實(shí)現(xiàn)方法

    這篇文章主要介紹了java讀取圖片并轉(zhuǎn)化為二進(jìn)制字符串的實(shí)例代碼,非常不錯(cuò),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2018-09-09
  • SpringCloud Eureka服務(wù)發(fā)現(xiàn)實(shí)現(xiàn)過(guò)程

    SpringCloud Eureka服務(wù)發(fā)現(xiàn)實(shí)現(xiàn)過(guò)程

    這篇文章主要介紹了SpringCloud Eureka服務(wù)發(fā)現(xiàn)實(shí)現(xiàn)過(guò)程,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2019-11-11
  • ireport數(shù)據(jù)表格報(bào)表的簡(jiǎn)單使用

    ireport數(shù)據(jù)表格報(bào)表的簡(jiǎn)單使用

    這篇文章給大家介紹了如何畫(huà)一個(gè)報(bào)表模板,這里介紹下畫(huà)表格需要用到的組件,文中通過(guò)圖文并茂的形式給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友參考下吧
    2021-10-10
  • springboot?實(shí)現(xiàn)不同context-path下的會(huì)話共享

    springboot?實(shí)現(xiàn)不同context-path下的會(huì)話共享

    這篇文章主要介紹了springboot?實(shí)現(xiàn)不同context-path下的會(huì)話共享,基于很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-01-01
  • Springmvc ResponseBody響應(yīng)json數(shù)據(jù)實(shí)現(xiàn)過(guò)程

    Springmvc ResponseBody響應(yīng)json數(shù)據(jù)實(shí)現(xiàn)過(guò)程

    這篇文章主要介紹了Springmvc ResponseBody響應(yīng)json數(shù)據(jù)實(shí)現(xiàn)過(guò)程,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-10-10

最新評(píng)論