You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2020/03/04 22:50:00 UTC
[jira] [Created] (KAFKA-9655) Flaky Test
SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe
Matthias J. Sax created KAFKA-9655:
--------------------------------------
Summary: Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe
Key: KAFKA-9655
URL: https://issues.apache.org/jira/browse/KAFKA-9655
Project: Kafka
Issue Type: Bug
Components: core, security, unit tests
Reporter: Matthias J. Sax
[https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/983/testReport/junit/kafka.api/SaslPlainSslEndToEndAuthorizationTest/testNoConsumeWithoutDescribeAclViaSubscribe/]
{quote}
h3. Error Message
org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [topic2]
h3. Stacktrace
org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [topic2]
h3. Standard Output
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:38:33,457] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:38:33,464] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:38:33,633] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:38:33,634] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:38:38,435] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:38:38,441] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:38:39,588] ERROR [Consumer clientId=consumer-group-3, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:302) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:38:44,139] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:38:44,145] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) [2020-03-04 19:38:45,799] ERROR [Consumer clientId=consumer-group-4, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:302) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:38:46,356] ERROR [Consumer clientId=consumer-group-4, groupId=group] Topic authorization failed for topics [topic2] (org.apache.kafka.clients.Metadata:302) [2020-03-04 19:38:46,464] ERROR [Consumer clientId=consumer-group-4, groupId=group] Topic authorization failed for topics [topic2] (org.apache.kafka.clients.Metadata:302) [2020-03-04 19:38:47,971] ERROR [Consumer clientId=consumer-group-4, groupId=group] Topic authorization failed for topics [topic2] (org.apache.kafka.clients.Metadata:302) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:38:54,138] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:38:54,137] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:38:54,307] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:38:54,307] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2e, patternType=PREFIXED)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=gr, patternType=PREFIXED)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2e, patternType=PREFIXED)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=gr, patternType=PREFIXED)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:00,406] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:00,406] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:00,711] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:00,715] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:06,857] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:06,864] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:07,078] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:07,080] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:14,784] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:14,793] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:14,999] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:14,999] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:15,749] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:15,749] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:23,110] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:23,114] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:23,291] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:23,292] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=*, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=*, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:29,787] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:29,788] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:29,989] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:29,991] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:38,014] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:38,016] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) [2020-03-04 19:39:39,626] ERROR [Consumer clientId=consumer-group-11, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:302) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:44,400] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:44,407] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:44,591] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:44,591] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:50,293] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:50,294] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:50,603] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:50,605] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:56,080] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:56,080] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:56,261] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:56,263] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:56,748] ERROR [Producer clientId=producer-12] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:302) [2020-03-04 19:39:56,776] ERROR [Consumer clientId=consumer-group-13, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:302) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:39:57,432] ERROR [Producer clientId=producer-12] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:302) [2020-03-04 19:39:57,474] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:57,474] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition topic2-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:39:57,535] ERROR [Producer clientId=producer-12] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:302) [2020-03-04 19:39:58,605] ERROR [Consumer clientId=consumer-group-13, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:302) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:admin, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:admin, host=*, operation=READ, permissionType=ALLOW) [2020-03-04 19:40:05,013] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:40:05,018] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition __consumer_offsets-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:40:05,222] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. [2020-03-04 19:40:05,226] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition e2etopic-0 at offset 0 (kafka.server.ReplicaFetcherThread:76) org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:user, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:user, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:user, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:user, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:user, host=*, operation=READ, permissionType=ALLOW){quote}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)