kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jason Gustafson (JIRA)" <j...@apache.org>
Subject [jira] [Assigned] (KAFKA-6118) Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials
Date Sat, 02 Dec 2017 05:33:00 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-6118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Jason Gustafson reassigned KAFKA-6118:
--------------------------------------

    Assignee: Jason Gustafson

> Transient failure in kafka.api.SaslScramSslEndToEndAuthorizationTest.testTwoConsumersWithDifferentSaslCredentials
> -----------------------------------------------------------------------------------------------------------------
>
>                 Key: KAFKA-6118
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6118
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: core, unit tests
>    Affects Versions: 1.0.0
>            Reporter: Guozhang Wang
>            Assignee: Jason Gustafson
>
> Saw this failure on trunk jenkins job:
> https://builds.apache.org/job/kafka-pr-jdk9-scala2.12/2274/testReport/junit/kafka.api/SaslScramSslEndToEndAuthorizationTest/testTwoConsumersWithDifferentSaslCredentials/
> {code}
> Stacktrace
> org.apache.kafka.common.errors.GroupAuthorizationException: Not authorized to access
group: group
> Standard Output
> [2017-10-25 15:09:49,986] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:09:50,654] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 2 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:09:50,654] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 2 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-user has Allow permission for operations: Create from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: *
> 	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> [2017-10-25 15:09:52,788] ERROR Error while creating ephemeral at /controller with return
code: OK (kafka.controller.KafkaControllerZkUtils$CheckedEphemeral:101)
> [2017-10-25 15:09:54,078] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-25 15:09:54,112] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:09:54,739] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 2 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:09:54,739] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 2 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-user has Allow permission for operations: Create from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>   
> [2017-10-25 15:09:57,096] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-25 15:09:57,108] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:09:57,786] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 1 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:09:57,802] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 1 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-user has Allow permission for operations: Create from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: *
> 	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> [2017-10-25 15:10:02,533] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-25 15:10:02,552] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:10:03,142] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 0 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:10:03,151] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 0 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-user has Allow permission for operations: Create from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> [2017-10-25 15:10:04,127] ERROR [Consumer clientId=consumer-93, groupId=group] Offset
commit failed on partition e2etopic-0 at offset 0: Not authorized to access topics: [Topic
authorization failed.] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:301)
> [2017-10-25 15:10:04,127] ERROR [Consumer clientId=consumer-93, groupId=group] Not authorized
to commit to topics [e2etopic] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:291)
> [2017-10-25 15:10:04,128] ERROR [Consumer clientId=consumer-93, groupId=group] Offset
commit failed on partition e2etopic-0 at offset 0: Not authorized to access topics: [Topic
authorization failed.] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:301)
> [2017-10-25 15:10:04,128] ERROR [Consumer clientId=consumer-93, groupId=group] Not authorized
to commit to topics [e2etopic] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:291)
> [2017-10-25 15:10:05,292] ERROR Error while creating ephemeral at /controller with return
code: OK (kafka.controller.KafkaControllerZkUtils$CheckedEphemeral:101)
> [2017-10-25 15:10:05,657] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-25 15:10:05,674] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:10:06,294] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 1 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:10:06,321] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 1 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-user has Allow permission for operations: Create from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> [2017-10-25 15:10:07,391] ERROR [Consumer clientId=consumer-95, groupId=group] Offset
commit failed on partition e2etopic-0 at offset 0: Not authorized to access topics: [Topic
authorization failed.] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:301)
> [2017-10-25 15:10:07,392] ERROR [Consumer clientId=consumer-95, groupId=group] Not authorized
to commit to topics [e2etopic] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:291)
> [2017-10-25 15:10:08,622] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-25 15:10:08,637] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:10:09,353] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 2 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:10:09,353] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 2 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-user has Allow permission for operations: Create from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>   
> [2017-10-25 15:10:11,668] ERROR Error while creating ephemeral at /controller with return
code: OK (kafka.controller.KafkaControllerZkUtils$CheckedEphemeral:101)
> [2017-10-25 15:10:11,836] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-25 15:10:11,846] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:10:12,563] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 0 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:10:12,587] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 0 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-user has Allow permission for operations: Create from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> [2017-10-25 15:10:15,010] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-25 15:10:15,020] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:10:15,663] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 2 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:10:15,663] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 2 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Describe from hosts: * 
> [2017-10-25 15:10:18,184] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-25 15:10:18,201] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:10:19,036] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 1 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:10:19,061] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 1 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-user has Allow permission for operations: Create from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: * 
> Adding ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:e2etopic`: 
>  	User:scram-user has Allow permission for operations: Write from hosts: *
> 	User:scram-user has Allow permission for operations: Describe from hosts: *
> 	User:scram-user has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Group:group`: 
>  	User:scram-user has Allow permission for operations: Read from hosts: * 
> [2017-10-25 15:10:19,678] WARN caught end of stream exception (org.apache.zookeeper.server.NIOServerCnxn:368)
> EndOfStreamException: Unable to read additional data from client sessionid 0x15f541588570014,
likely client has closed socket
> 	at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:239)
> 	at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
> 	at java.base/java.lang.Thread.run(Thread.java:844)
> [2017-10-25 15:10:21,539] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> [2017-10-25 15:10:21,552] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> Adding ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Current ACLs for resource `Cluster:kafka-cluster`: 
>  	User:scram-admin has Allow permission for operations: ClusterAction from hosts: * 
> Completed Updating config for entity: user-principal 'scram-admin'.
> [2017-10-25 15:10:22,276] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 0 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> [2017-10-25 15:10:22,297] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0]
Error for partition __consumer_offsets-0 from broker 0 (kafka.server.ReplicaFetcherThread:107)
> org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access
topics: [Topic authorization failed.]
> Adding ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Current ACLs for resource `Topic:*`: 
>  	User:scram-admin has Allow permission for operations: Read from hosts: * 
> Completed Updating config for entity: user-principal 'scram-user'.
> Completed Updating config for entity: user-principal 'scram-user2'.
> [2017-10-25 15:10:24,574] ERROR ZKShutdownHandler is not registered, so ZooKeeper server
won't take any action on ERROR or SHUTDOWN server state changes (org.apache.zookeeper.server.ZooKeeperServer:472)
> {code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message