[KAFKA-9655] Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Open
Priority: Critical
Resolution: Unresolved
Affects Version/s: None
Fix Version/s: None
Component/s: core, security, unit tests
Labels:
- flaky-test

Description

https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/983/testReport/junit/kafka.api/SaslPlainSslEndToEndAuthorizationTest/testNoConsumeWithoutDescribeAclViaSubscribe/

Error Message

org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [topic2]

Stacktrace

org.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [topic2]

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)

Attachments

Activity

People

Assignee:: Unassigned

Reporter:: Matthias J. Sax

Votes:: 0 Vote for this issue

Watchers:: 1 Start watching this issue

Dates

Created:: 04/Mar/20 22:49

Updated:: 04/Mar/20 22:49