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)
