[
https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16961333#comment-16961333
]
Guozhang Wang commented on KAFKA-8677:
--------------------------------------
This flaky test has been pretty frequent recently, [~anastasiavela] are you
still working on that?
Just to bring a few more examples:
https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/26200/testReport/junit/kafka.api/DelegationTokenEndToEndAuthorizationTest/testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl/
https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/2992/testReport/junit/kafka.api/SaslPlainSslEndToEndAuthorizationTest/testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl/
https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/8985/testReport/junit/kafka.api/SslEndToEndAuthorizationTest/testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl/
And they all exposed the same error trace:
{code}
Stacktrace
org.junit.ComparisonFailure: expected:<[e2etopic]> but was:<[topic2]>
at org.junit.Assert.assertEquals(Assert.java:117)
at org.junit.Assert.assertEquals(Assert.java:146)
at
kafka.api.EndToEndAuthorizationTest$$anonfun$consumeRecords$1.apply$mcVI$sp(EndToEndAuthorizationTest.scala:535)
at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:160)
at
kafka.api.EndToEndAuthorizationTest.consumeRecords(EndToEndAuthorizationTest.scala:532)
at
kafka.api.EndToEndAuthorizationTest.consumeRecordsIgnoreOneAuthorizationException(EndToEndAuthorizationTest.scala:549)
at
kafka.api.EndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl(EndToEndAuthorizationTest.scala:369)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:305)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:365)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:330)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:78)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:328)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:65)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:292)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:305)
at org.junit.runners.ParentRunner.run(ParentRunner.java:412)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.runTestClass(JUnitTestClassExecutor.java:110)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:58)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecutor.execute(JUnitTestClassExecutor.java:38)
at
org.gradle.api.internal.tasks.testing.junit.AbstractJUnitTestClassProcessor.processTestClass(AbstractJUnitTestClassProcessor.java:62)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
at sun.reflect.GeneratedMethodAccessor44.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33)
at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:118)
at sun.reflect.GeneratedMethodAccessor43.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:182)
at
org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:164)
at
org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:412)
at
org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64)
at
org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:48)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at
org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56)
at java.lang.Thread.run(Thread.java:748)
{code}
{code}
Standard Output
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:57:29,818] 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-10-28 00:57:29,820] 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-10-28 00:57:29,988] 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-10-28 00:57:29,988] 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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Create from hosts:
*
[2019-10-28 00:57:31,626] ERROR [Consumer clientId=consumer-group-2044,
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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Read from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
[2019-10-28 00:57:32,181] ERROR [Consumer clientId=consumer-group-2044,
groupId=group] Topic authorization failed for topics [topic2]
(org.apache.kafka.clients.Metadata:283)
[2019-10-28 00:57:32,182] ERROR [Consumer clientId=consumer-group-2044,
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:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:57:40,395] 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-10-28 00:57:40,403] ERROR [ReplicaFetcher replicaId=0, leaderId=2,
fetcherId=0] Error for partition __consumer_offsets-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2e,
patternType=PREFIXED)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=gr,
patternType=PREFIXED)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:PREFIXED:e2e`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Read from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Current ACLs for resource `Group:PREFIXED:gr`:
User:scram-user has Allow permission for operations: Read from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:57:46,626] 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-10-28 00:57:46,628] 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-10-28 00:57:46,893] 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-10-28 00:57:46,894] 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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Read from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:57:54,061] 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-10-28 00:57:54,063] 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-10-28 00:57:54,270] 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-10-28 00:57:54,272] 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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:58:01,590] 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-10-28 00:58:01,593] 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-10-28 00:58:01,800] 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-10-28 00:58:01,802] 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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:topic2`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:topic2`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Read from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
[2019-10-28 00:58:02,494] 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-10-28 00:58:02,509] 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.
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:58:08,996] 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-10-28 00:58:08,996] ERROR [ReplicaFetcher replicaId=0, leaderId=2,
fetcherId=0] Error for partition __consumer_offsets-0 at offset 0
(kafka.server.ReplicaFetcherThread:76)
org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server
does not host this topic-partition.
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=*,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts: *
User:scram-user has Allow permission for operations: Read from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
User:scram-user has Allow permission for operations: Write from hosts:
*
Current ACLs for resource `Group:LITERAL:*`:
User:scram-user has Allow permission for operations: Read from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:58:18,040] 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-10-28 00:58:18,044] 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-10-28 00:58:18,253] 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-10-28 00:58:18,253] 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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:58:25,598] 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-10-28 00:58:25,598] 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.
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Create from hosts:
*
[2019-10-28 00:58:27,063] ERROR [Consumer clientId=consumer-group-2051,
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:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:58:32,850] 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-10-28 00:58:32,857] 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-10-28 00:58:33,058] 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-10-28 00:58:33,058] 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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:58:41,349] 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-10-28 00:58:41,351] 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-10-28 00:58:41,660] 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-10-28 00:58:41,661] 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:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:58:49,017] 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-10-28 00:58:49,034] 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-10-28 00:58:49,218] 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-10-28 00:58:49,222] 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:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
[2019-10-28 00:58:49,686] ERROR [Producer clientId=producer-501] Topic
authorization failed for topics [e2etopic]
(org.apache.kafka.clients.Metadata:283)
[2019-10-28 00:58:49,732] ERROR [Consumer clientId=consumer-group-2053,
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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:topic2`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=topic2,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:topic2`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Read from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
[2019-10-28 00:58:50,395] ERROR [Producer clientId=producer-501] Topic
authorization failed for topics [e2etopic]
(org.apache.kafka.clients.Metadata:283)
[2019-10-28 00:58:50,462] 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-10-28 00:58:50,464] 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-10-28 00:58:50,497] ERROR [Producer clientId=producer-501] Topic
authorization failed for topics [e2etopic]
(org.apache.kafka.clients.Metadata:283)
[2019-10-28 00:58:51,661] ERROR [Consumer clientId=consumer-group-2053,
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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Read from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=CLUSTER,
name=kafka-cluster, patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=CLUSTER_ACTION,
permissionType=ALLOW)
Current ACLs for resource `Cluster:LITERAL:kafka-cluster`:
User:scram-admin has Allow permission for operations: ClusterAction
from hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=*,
patternType=LITERAL)`:
(principal=User:scram-admin, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:*`:
User:scram-admin has Allow permission for operations: Read from hosts:
*
Completed Updating config for entity: user-principal 'scram-admin'.
Completed Updating config for entity: user-principal 'scram-user'.
[2019-10-28 00:58:57,952] 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-10-28 00:58:57,952] 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-10-28 00:58:58,124] 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-10-28 00:58:58,124] 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:scram-user, host=*, operation=WRITE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=CREATE,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Adding ACLs for resource `ResourcePattern(resourceType=TOPIC, name=e2etopic,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
(principal=User:scram-user, host=*, operation=DESCRIBE,
permissionType=ALLOW)
Adding ACLs for resource `ResourcePattern(resourceType=GROUP, name=group,
patternType=LITERAL)`:
(principal=User:scram-user, host=*, operation=READ,
permissionType=ALLOW)
Current ACLs for resource `Topic:LITERAL:e2etopic`:
User:scram-user has Allow permission for operations: Write from hosts: *
User:scram-user has Allow permission for operations: Read from hosts: *
User:scram-user has Allow permission for operations: Create from hosts:
*
User:scram-user has Allow permission for operations: Describe from
hosts: *
Current ACLs for resource `Group:LITERAL:group`:
User:scram-user has Allow permission for operations: Read from hosts: *
{code}
> Flakey test
> GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
> ------------------------------------------------------------------------------------------------
>
> Key: KAFKA-8677
> URL: https://issues.apache.org/jira/browse/KAFKA-8677
> Project: Kafka
> Issue Type: Bug
> Components: core, security, unit tests
> Affects Versions: 2.4.0
> Reporter: Boyang Chen
> Assignee: Anastasia Vela
> Priority: Major
> Labels: flaky-test
>
> [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/6325/console]
>
> *18:43:39* kafka.api.GroupEndToEndAuthorizationTest >
> testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl STARTED*18:44:00*
> kafka.api.GroupEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl
> failed, log available in
> /home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.12/core/build/reports/testOutput/kafka.api.GroupEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl.test.stdout*18:44:00*
> *18:44:00* kafka.api.GroupEndToEndAuthorizationTest >
> testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl FAILED*18:44:00*
> org.scalatest.exceptions.TestFailedException: Consumed 0 records before
> timeout instead of the expected 1 records
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
