jak korzystać z kafka acls?

Question

Moja wersja kafka to 0.9.0.1 i mam dwóch brokerów: 192.168.1.100, 192.168.1.101 używających ssl do uwierzytelniania i szyfrowania.

miałem temat o nazwie test09 i IP klienta jest 192.168.1.102

kiedy dodać ACL z interfejsem wiersza poleceń jak poniżej:

bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --deny-principal User:* --deny-host 192.168.1.102 --operation Read --topic test09 

konsument od 192.168.1.102 można jeszcze dostać dane.

Czy ktoś może mi powiedzieć, jak używać list ACL w kafejce?

Answer 1

wierzę pominięcia aby dodać właściwość poniżej Server.properties

authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer 

- Dodanie tej linii pozwoliłoby ACL do pracy poprzez SimpleAclAuthorizer. - Kafka domyślnie jest dostarczany z kafka.security.auth.SimpleAclAuthorizer zdefiniowanym przez parametr authorizer.class.name.

Możesz wypróbować poniższe ustawienia, które mogą dać pełny pomysł.

https://github.com/Symantec/kafka-security-0.9