も、ACL

Question

を構成した後、私はカフカに全く新たなんだと私はトピックのために設定されたACLに必要と私は以下試したカフカのトピックを生成することができます： -

./kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 \ --add --allow-principal User:Bob \ --producer --topic newtopic 

を理想的には、ボブ以外のプロデューサーがすべきトピックで制作することは許可されていませんが、私はそれをプロデューサーの設定に従って生産することができます。

Properties props = new Properties(); 
    props.put("bootstrap.servers", "localhost:9092"); 
    props.put("client.id", "DemoProducer"); 
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); 
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); 
    producerConfig = new KafkaProducer<String, String>(props); 
    this.topic = topic; 
    this.isAsync = isAsync; 

さらに、ACLを有効にするために必要なプロデューサ設定がありますか？お勧めします。

Answer 1

@Apollo：IPアドレス/ユーザー名などでブロックすることができます。この行を追加すると、経由で動作するようにACLを可能にする - 私はあなたがServer.properties

= kafka.security.auth.SimpleAclAuthorizer

authorizer.class.nameに以下のプロパティを追加するために見逃していると考えていることの一つSimpleAclAuthorizer。 - カフカのデフォルトでは、パラメータauthorizer.class.nameによって定義されたkafka.security.auth.SimpleAclAuthorizerが付属します。

あなたは完全なアイデアを与えるかもしれない以下の設定を試すことができます。

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