Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9655

Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoConsumeWithoutDescribeAclViaSubscribe

    XMLWordPrintableJSON

    Details

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

      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:
              mjsax Matthias J. Sax
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: