[ https://issues.apache.org/jira/browse/KAFKA-9181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16974343#comment-16974343 ]
Bill Bejeck commented on KAFKA-9181: ------------------------------------ Failed again in [https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/3358/] on 11/14/19 {noformat} Error Messageorg.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [topic2]Stacktraceorg.apache.kafka.common.errors.TopicAuthorizationException: Not authorized to access topics: [topic2] Standard OutputAdding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka15290895624380393501.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 00:58:37,287] 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. [2019-11-14 00:58:37,304] 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. [2019-11-14 00:58:37,474] 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. [2019-11-14 00:58:37,490] 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. Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * User:client has Allow permission for operations: Read from hosts: * Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka6561302204353356505.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka6561302204353356505.tmp refreshKrb5Config is false principal is clie...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is clie...@example.com Will use keytab Commit Succeeded [2019-11-14 00:58:38,702] ERROR [Consumer clientId=consumer-group-123, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:283) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka14571018816684750392.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 00:59:01,454] 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. [2019-11-14 00:59:01,453] 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. [2019-11-14 00:59:01,638] 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. [2019-11-14 00:59:01,638] 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:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka8347317469778808373.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Create from hosts: * [2019-11-14 00:59:03,227] ERROR [Consumer clientId=consumer-group-124, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:283) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * User:client has Allow permission for operations: Read from hosts: * Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * [2019-11-14 00:59:03,763] ERROR [Consumer clientId=consumer-group-124, groupId=group] Topic authorization failed for topics [topic2] (org.apache.kafka.clients.Metadata:283) [2019-11-14 00:59:03,766] ERROR [Consumer clientId=consumer-group-124, groupId=group] Topic authorization failed for topics [topic2] (org.apache.kafka.clients.Metadata:283) [2019-11-14 00:59:05,270] ERROR [Consumer clientId=consumer-group-124, groupId=group] Topic authorization failed for topics [topic2] (org.apache.kafka.clients.Metadata:283) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka13029856880541949269.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 00:59:26,542] 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. [2019-11-14 00:59:26,542] 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. [2019-11-14 00:59:26,750] 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. [2019-11-14 00:59:26,757] 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=e2e, patternType=PREFIXED)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=gr, patternType=PREFIXED)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:PREFIXED:e2e`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * User:client has Allow permission for operations: Read from hosts: * Current ACLs for resource `Group:PREFIXED:gr`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka6088574624537718013.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka7469658214928529291.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 00:59:49,789] 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. [2019-11-14 00:59:49,993] 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. [2019-11-14 00:59:50,000] 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:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * User:client has Allow permission for operations: Read from hosts: * Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka10092050242584436880.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka4752948686662024739.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 01:00:19,801] 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. [2019-11-14 01:00:19,802] 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. [2019-11-14 01:00:19,999] 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. [2019-11-14 01:00:19,999] 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:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka17975749946103788919.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka6211608820863669201.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 01:00:43,661] 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. [2019-11-14 01:00:43,666] 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. [2019-11-14 01:00:43,880] 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. [2019-11-14 01:00:43,881] 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=topic2, patternType=LITERAL)`: (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:topic2`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:topic2`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * User:client has Allow permission for operations: Read from hosts: * Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka13580752757834126408.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded [2019-11-14 01:00:44,578] ERROR [ReplicaFetcher replicaId=2, leaderId=0, 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. [2019-11-14 01:00:44,578] ERROR [ReplicaFetcher replicaId=1, leaderId=0, 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:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka9221698973638093027.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 01:01:12,267] 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. [2019-11-14 01:01:12,278] 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. [2019-11-14 01:01:12,469] 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. [2019-11-14 01:01:12,486] 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=*, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=*, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:client has Allow permission for operations: Write from hosts: * User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Read from hosts: * User:kafka has Allow permission for operations: Read from hosts: * User:client has Allow permission for operations: Create from hosts: * Current ACLs for resource `Group:LITERAL:*`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka7749679852872205789.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka777035443037790769.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 01:01:37,428] 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. [2019-11-14 01:01:37,428] 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. [2019-11-14 01:01:37,643] 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. [2019-11-14 01:01:37,648] 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:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka1993279303170600061.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka10137267044708183264.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 01:02:02,047] 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. [2019-11-14 01:02:02,051] 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. [2019-11-14 01:02:02,260] 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. [2019-11-14 01:02:02,266] 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:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka2378892307444116935.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Create from hosts: * [2019-11-14 01:02:03,887] ERROR [Consumer clientId=consumer-group-131, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:283) Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka17697454570176860746.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 01:02:26,341] 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. [2019-11-14 01:02:26,351] 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. [2019-11-14 01:02:26,563] 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. [2019-11-14 01:02:26,563] 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:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka9624121587150447769.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka13866155282540711107.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 01:02:48,677] 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. [2019-11-14 01:02:48,689] 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. [2019-11-14 01:02:48,882] 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. [2019-11-14 01:02:48,886] 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:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka12414618500290383241.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka4719537482188960558.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 01:03:08,341] 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. [2019-11-14 01:03:08,354] 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. [2019-11-14 01:03:08,545] 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. [2019-11-14 01:03:08,545] 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=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka10429787789810189752.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded [2019-11-14 01:03:08,982] ERROR [Producer clientId=producer-128] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:283) [2019-11-14 01:03:09,009] ERROR [Consumer clientId=consumer-group-133, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:283) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:topic2`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:topic2`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * User:client has Allow permission for operations: Read from hosts: * Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * [2019-11-14 01:03:09,582] ERROR [Producer clientId=producer-128] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:283) [2019-11-14 01:03:09,612] ERROR [ReplicaFetcher replicaId=2, leaderId=1, 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. [2019-11-14 01:03:09,621] ERROR [ReplicaFetcher replicaId=0, leaderId=1, 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. [2019-11-14 01:03:09,683] ERROR [Producer clientId=producer-128] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:283) [2019-11-14 01:03:10,799] ERROR [Consumer clientId=consumer-group-133, groupId=group] Topic authorization failed for topics [e2etopic] (org.apache.kafka.clients.Metadata:283) Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * User:client has Allow permission for operations: Read from hosts: * Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=CLUSTER_ACTION, permissionType=ALLOW) Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: User:kafka has Allow permission for operations: ClusterAction from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, patternType=LITERAL)`: (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:*`: User:kafka has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka8280054279144836016.tmp refreshKrb5Config is false principal is kafka/localh...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is kafka/localh...@example.com Will use keytab Commit Succeeded [2019-11-14 01:03:33,512] 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. [2019-11-14 01:03:33,715] 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. [2019-11-14 01:03:33,720] 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:client, host=*, operation=CREATE, permissionType=ALLOW) (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) (principal=User:client, host=*, operation=DESCRIBE, permissionType=ALLOW) Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, patternType=LITERAL)`: (principal=User:client, host=*, operation=READ, permissionType=ALLOW) Current ACLs for resource `Topic:LITERAL:e2etopic`: User:client has Allow permission for operations: Describe from hosts: * User:client has Allow permission for operations: Create from hosts: * User:client has Allow permission for operations: Write from hosts: * User:client has Allow permission for operations: Read from hosts: * Current ACLs for resource `Group:LITERAL:group`: User:client has Allow permission for operations: Read from hosts: * Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt false ticketCache is null isInitiator true KeyTab is /tmp/kafka710823969989408103.tmp refreshKrb5Config is false principal is cli...@example.com tryFirstPass is false useFirstPass is false storePass is false clearPass is false principal is cli...@example.com Will use keytab Commit Succeeded {noformat} > Flaky test > kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoConsumeWithoutDescribeAclViaSubscribe > ------------------------------------------------------------------------------------------------------- > > Key: KAFKA-9181 > URL: https://issues.apache.org/jira/browse/KAFKA-9181 > Project: Kafka > Issue Type: Test > Components: core > Reporter: Bill Bejeck > Priority: Major > Labels: flaky-test, tests > > Failed in > [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/26571/testReport/junit/kafka.api/SaslGssapiSslEndToEndAuthorizationTest/testNoConsumeWithoutDescribeAclViaSubscribe/] > > {noformat} > Error Messageorg.apache.kafka.common.errors.TopicAuthorizationException: Not > authorized to access topics: > [topic2]Stacktraceorg.apache.kafka.common.errors.TopicAuthorizationException: > Not authorized to access topics: [topic2] > Standard OutputAdding ACLs for resource > `ResourcePattern(resourceType=CLUSTER, name=kafka-cluster, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka6494439724844851846.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:43:16,187] 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. > [2019-11-13 04:43:16,191] 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. > [2019-11-13 04:43:16,384] 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. > [2019-11-13 04:43:16,384] 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:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Read from hosts: * > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka3083328529571706878.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka3083328529571706878.tmp refreshKrb5Config is false principal is > clie...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is clie...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:43:17,549] ERROR [Consumer clientId=consumer-group-255, > groupId=group] Topic authorization failed for topics [e2etopic] > (org.apache.kafka.clients.Metadata:283) > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka2790389872392408045.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:43:43,513] 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. > [2019-11-13 04:43:43,513] 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. > [2019-11-13 04:43:43,682] 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. > [2019-11-13 04:43:43,683] 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:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka3639280670011131711.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Create from hosts: * > [2019-11-13 04:43:45,193] ERROR [Consumer clientId=consumer-group-256, > groupId=group] Topic authorization failed for topics [e2etopic] > (org.apache.kafka.clients.Metadata:283) > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Create from hosts: * > User:client has Allow permission for operations: Write from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Read from hosts: * > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Create from hosts: * > User:client has Allow permission for operations: Write from hosts: * > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > [2019-11-13 04:43:45,698] ERROR [Consumer clientId=consumer-group-256, > groupId=group] Topic authorization failed for topics [topic2] > (org.apache.kafka.clients.Metadata:283) > [2019-11-13 04:43:45,700] ERROR [Consumer clientId=consumer-group-256, > groupId=group] Topic authorization failed for topics [topic2] > (org.apache.kafka.clients.Metadata:283) > [2019-11-13 04:43:47,205] ERROR [Consumer clientId=consumer-group-256, > groupId=group] Topic authorization failed for topics [topic2] > (org.apache.kafka.clients.Metadata:283) > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka2853735962705514989.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:44:10,330] 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. > [2019-11-13 04:44:10,331] 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. > [2019-11-13 04:44:10,531] 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. > [2019-11-13 04:44:10,531] 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=e2e, > patternType=PREFIXED)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=gr, > patternType=PREFIXED)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:PREFIXED:e2e`: > User:client has Allow permission for operations: Read from hosts: * > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Group:PREFIXED:gr`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka3614118284002283090.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka3343806238750489399.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:44:42,245] 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. > [2019-11-13 04:44:42,262] 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. > [2019-11-13 04:44:42,453] 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. > [2019-11-13 04:44:42,461] 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:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Read from hosts: * > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka2293718255849931457.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka8247896269514574204.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:45:09,679] 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. > [2019-11-13 04:45:09,687] 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. > [2019-11-13 04:45:09,901] 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. > [2019-11-13 04:45:09,902] 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:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka6165264118808778893.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka5588216719148826164.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:45:44,360] 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. > [2019-11-13 04:45:44,366] 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. > [2019-11-13 04:45:44,553] 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. > [2019-11-13 04:45:44,553] 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=topic2, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:topic2`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:topic2`: > User:client has Allow permission for operations: Read from hosts: * > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka8937168000923149954.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:45:45,239] ERROR [ReplicaFetcher replicaId=1, leaderId=0, > 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. > [2019-11-13 04:45:45,239] ERROR [ReplicaFetcher replicaId=2, leaderId=0, > 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:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka1753713975062534365.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:46:13,255] 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. > [2019-11-13 04:46:13,261] 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. > [2019-11-13 04:46:13,522] 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. > [2019-11-13 04:46:13,527] 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. > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=*, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Read from hosts: * > User:kafka has Allow permission for operations: Read from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Group:LITERAL:*`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka4579277064687399324.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka1211513173897695002.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:46:38,320] 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. > [2019-11-13 04:46:38,323] 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. > [2019-11-13 04:46:38,521] 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. > [2019-11-13 04:46:38,526] 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:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka4859545116775501587.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka5936495479832727441.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:47:13,934] 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. > [2019-11-13 04:47:13,939] 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. > [2019-11-13 04:47:14,142] 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. > [2019-11-13 04:47:14,143] 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:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka5030780877268645002.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Create from hosts: * > [2019-11-13 04:47:15,675] ERROR [Consumer clientId=consumer-group-263, > groupId=group] Topic authorization failed for topics [e2etopic] > (org.apache.kafka.clients.Metadata:283) > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka2819838905642285118.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:47:43,623] 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. > [2019-11-13 04:47:43,635] 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. > [2019-11-13 04:47:43,831] 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. > [2019-11-13 04:47:43,831] 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:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka7821381619195888442.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka7294747755465828555.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:48:13,692] 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. > [2019-11-13 04:48:13,705] 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. > [2019-11-13 04:48:13,880] 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. > [2019-11-13 04:48:13,884] 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:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka2522835534939702730.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka8641154754165823659.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:48:39,064] 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. > [2019-11-13 04:48:39,074] 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. > [2019-11-13 04:48:39,267] 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. > [2019-11-13 04:48:39,268] 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:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka4420357362687484380.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:48:39,713] ERROR [Producer clientId=producer-422] Topic > authorization failed for topics [e2etopic] > (org.apache.kafka.clients.Metadata:283) > [2019-11-13 04:48:39,740] ERROR [Consumer clientId=consumer-group-265, > groupId=group] Topic authorization failed for topics [e2etopic] > (org.apache.kafka.clients.Metadata:283) > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:topic2`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:topic2`: > User:client has Allow permission for operations: Read from hosts: * > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > [2019-11-13 04:48:40,327] ERROR [Producer clientId=producer-422] Topic > authorization failed for topics [e2etopic] > (org.apache.kafka.clients.Metadata:283) > [2019-11-13 04:48:40,429] ERROR [Producer clientId=producer-422] Topic > authorization failed for topics [e2etopic] > (org.apache.kafka.clients.Metadata:283) > [2019-11-13 04:48:41,185] ERROR [Consumer clientId=consumer-group-265, > groupId=group] Topic authorization failed for topics [e2etopic] > (org.apache.kafka.clients.Metadata:283) > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Read from hosts: * > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER, > name=kafka-cluster, patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=CLUSTER_ACTION, > permissionType=ALLOW) > Current ACLs for resource `Cluster:LITERAL:kafka-cluster`: > User:kafka has Allow permission for operations: ClusterAction from > hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*, > patternType=LITERAL)`: > (principal=User:kafka, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:*`: > User:kafka has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka8725022246516193653.tmp refreshKrb5Config is false principal is > kafka/localh...@example.com tryFirstPass is false useFirstPass is false > storePass is false clearPass is false > principal is kafka/localh...@example.com > Will use keytab > Commit Succeeded > [2019-11-13 04:49:10,578] 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. > [2019-11-13 04:49:10,578] 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. > [2019-11-13 04:49:10,775] 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. > [2019-11-13 04:49:10,780] 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. > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=WRITE, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > (principal=User:client, host=*, operation=CREATE, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > (principal=User:client, host=*, operation=DESCRIBE, > permissionType=ALLOW) > Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group, > patternType=LITERAL)`: > (principal=User:client, host=*, operation=READ, permissionType=ALLOW) > Current ACLs for resource `Topic:LITERAL:e2etopic`: > User:client has Allow permission for operations: Read from hosts: * > User:client has Allow permission for operations: Describe from hosts: * > User:client has Allow permission for operations: Write from hosts: * > User:client has Allow permission for operations: Create from hosts: * > Current ACLs for resource `Group:LITERAL:group`: > User:client has Allow permission for operations: Read from hosts: * > Debug is true storeKey true useTicketCache false useKeyTab true doNotPrompt > false ticketCache is null isInitiator true KeyTab is > /tmp/kafka6140470407592077851.tmp refreshKrb5Config is false principal is > cli...@example.com tryFirstPass is false useFirstPass is false storePass is > false clearPass is false > principal is cli...@example.com > Will use keytab > Commit Succeeded {noformat} -- This message was sent by Atlassian Jira (v8.3.4#803005)