Courtier d'erreur de réplication “Pas autorisé à accéder aux rubriques: [Topic échec de l'autorisation.] ”

J'ai trois Kafka courtiers (kafka_2.11-0.10.0.0)et chaque courtier de sécurité est configuré comme ci-dessous, 

listeners=PLAINTEXT://xxxx:9093,SASL_PLAINTEXT://xxxx:10093
advertised.listeners=PLAINTEXT://xxxx:9093,SASL_PLAINTEXT://xxxx:10093
security.inter.broker.protocol=PLAINTEXT
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer
allow.everyone.if.no.acl.found=true
super.users=User:admin

kafka_server_jaas.conf également configuré avec l'utilisateur admin.

KafkaServer {
        org.apache.kafka.common.security.plain.PlainLoginModule required
        username="admin"
        password="welcome1"
        user_guest="welcome1";
};

Quand je connecte l'utilisation du texte CLAIR de l'écouteur et de produire et de consommer des messages, tout fonctionne bien.

mais quand j'essaie d'ajouter des listes de contrôle d'accès un certain sujet, le cluster de sortie des messages d'erreur comme ci-dessous: 

bin/kafka-acls.sh --authorizer-properties zookeeper.connect=xxxx:2181/kafka10  --add --allow-principal User:guest --producer --topic page_visits_10k

Courtier De Sortie 

[2016-05-31 10:49:57,497] ERROR [ReplicaFetcherThread-0-2], Error for partition [page_visits_10k,1] to broker 2:org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Topic authorization failed.] (kafka.server.ReplicaFetcherThread)
[2016-05-31 10:49:59,003] ERROR [ReplicaFetcherThread-0-2], Error for partition [page_visits_10k,1] to broker 2:org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Topic authorization failed.] (kafka.server.ReplicaFetcherThread)

Sortie d'erreur ressemble inter courtier erreur de réplication, d'apprécier pour toute aide.

InformationsquelleAutor Shawn Guo | 2016-05-31
  1. 2

    J'ai affronté problème similaire avec l'aide de l'Acl dans Kafka v. 0.10. J'ai trouvé cette discussion utile. En particulier l'activation de l'autorisation du journal afin de vérifier ce qui est l'utilisateur entrant pour la demande et ce qu'il est spécifié dans votre Acl.


    Autorisation journal peut être activée par modification de la log4j.propriétés dans le dossier config. Dans log4j.les propriétés de fichier, changement WARN à DEBUG et redémarrez l'kafka-serveurs. 

    log4j.logger.kafka.authorizer.logger=DEBUG, authorizerAppender

    Cela m'a aidé pour faire le tri dans ma question. Espérons que cela aide.

    PS: L'autorisation journaux générés seront très longues et de consommer beaucoup d'espace. Donc, n'oubliez pas de désactiver cette fonction lorsque le débogage.

    InformationsquelleAutor Sai Kiriti Badam
  2. 0

    Enfin je figure sur cette question.

    L'erreur est provoquée par:

    de sécurité.l'inter.courtier.protocole=PLAINTEXT

    Il devrait être:

    de sécurité.l'inter.courtier.protocole=SASL_PLAINTEXT 

    [2016-05-31 10:49:57,497] ERROR [ReplicaFetcherThread-0-2], Error for partition [page_visits_10k,1] to broker 2:org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Topic authorization failed.] (kafka.server.ReplicaFetcherThread)
[2016-05-31 10:49:59,003] ERROR [ReplicaFetcherThread-0-2], Error for partition [page_visits_10k,1] to broker 2:org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [Topic authorization failed.] (kafka.server.ReplicaFetcherThread)
    InformationsquelleAutor Shawn Guo
  3. 0

    Exécuter le script ci-dessous Après le démarrage de la gardienne et avant le démarrage de Kafka. 

    sh kafka_2.11-0.9.0.1/bin/kafka-acls.sh --authorizer-properties 
zookeeper.connect=localhost:2181 --operation All --allow-principal 
User:*   --allow-host <server host> --add --cluster`

    Cela permettra serveur local de la machine tous les ACL.

    InformationsquelleAutor supermonk