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

Flaky Test SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads

    XMLWordPrintableJSON

    Details

    • Type: Test
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.5.0
    • Component/s: core
    • Labels:

      Description

      Failed in https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/9373/testReport/junit/kafka.api/SslAdminClientIntegrationTest/testSynchronousAuthorizerAclUpdatesBlockRequestThreads/

       

      Error Messagejava.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Aborted due to timeout.Stacktracejava.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Aborted due to timeout.
      	at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
      	at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
      	at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
      	at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
      	at kafka.api.SslAdminClientIntegrationTest.$anonfun$testSynchronousAuthorizerAclUpdatesBlockRequestThreads$1(SslAdminClientIntegrationTest.scala:201)
      	at scala.collection.mutable.ResizableArray.foreach(ResizableArray.scala:62)
      	at scala.collection.mutable.ResizableArray.foreach$(ResizableArray.scala:55)
      	at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:49)
      	at kafka.api.SslAdminClientIntegrationTest.testSynchronousAuthorizerAclUpdatesBlockRequestThreads(SslAdminClientIntegrationTest.scala:201)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.base/java.lang.reflect.Method.invoke(Method.java:566)
      	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.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:288)
      	at org.junit.internal.runners.statements.FailOnTimeout$CallableStatement.call(FailOnTimeout.java:282)
      	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
      	at java.base/java.lang.Thread.run(Thread.java:834)
      Caused by: org.apache.kafka.common.errors.TimeoutException: Aborted due to timeout.
      Standard Output[2019-11-14 15:13:51,489] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition mytopic1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:13:51,490] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition mytopic1-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 15:14:04,686] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=4, api=CREATE_ACLS, version=1, body={creations=[{resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},{resource_type=5,resource_name=transactional_id,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:04,689] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=5, api=DELETE_ACLS, version=1, body={filters=[{resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},{resource_type=5,resource_name=transactional_id,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:04,795] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=7, api=DESCRIBE_ACLS, version=1, body={resource_type=2,resource_name=*,resource_pattern_type_filter=3,principal=User:*,host=*,operation=2,permission_type=3} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:04,796] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=8, api=CREATE_ACLS, version=1, body={creations=[{resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},{resource_type=5,resource_name=transactional_id,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:04,798] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=9, api=DELETE_ACLS, version=1, body={filters=[{resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},{resource_type=5,resource_name=transactional_id,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:04,930] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=18, api=DESCRIBE_ACLS, version=1, body={resource_type=2,resource_name=*,resource_pattern_type_filter=3,principal=User:*,host=*,operation=2,permission_type=3} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:04,931] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=19, api=CREATE_ACLS, version=1, body={creations=[{resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},{resource_type=5,resource_name=transactional_id,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:04,933] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=20, api=DELETE_ACLS, version=1, body={filters=[{resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},{resource_type=5,resource_name=transactional_id,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:04,937] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=21, api=DESCRIBE_ACLS, version=1, body={resource_type=2,resource_name=*,resource_pattern_type_filter=3,principal=User:*,host=*,operation=2,permission_type=3} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:05,040] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=23, api=CREATE_ACLS, version=1, body={creations=[{resource_type=2,resource_name=foobar,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},{resource_type=5,resource_name=transactional_id,resource_pattern_type=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:05,042] ERROR [KafkaApi-2] Error when handling request: clientId=adminclient-644, correlationId=24, api=DELETE_ACLS, version=1, body={filters=[{resource_type=2,resource_name=foobar,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=3,permission_type=3},{resource_type=5,resource_name=transactional_id,resource_pattern_type_filter=3,principal=User:ANONYMOUS,host=*,operation=4,permission_type=3}]} (kafka.server.KafkaApis:76)
      org.apache.kafka.common.errors.ClusterAuthorizationException: Request Request(processor=1, connectionId=127.0.0.1:41993-127.0.0.1:34770-0, session=Session(User:ANONYMOUS,/127.0.0.1), listenerName=ListenerName(SSL), securityProtocol=SSL, buffer=null) is not authorized.
      [2019-11-14 15:14:53,171] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-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 15:15:01,790] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition topic-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 15:15:01,792] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition topic-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 15:15:09,941] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-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 15:15:09,943] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:15:20,683] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition elect-preferred-leaders-topic-1-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 15:15:20,686] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition elect-preferred-leaders-topic-1-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 15:15:20,865] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition elect-preferred-leaders-topic-2-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 15:15:20,865] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition elect-preferred-leaders-topic-2-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 15:15:36,402] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition list-reassignments-no-reassignments-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 15:15:36,405] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition list-reassignments-no-reassignments-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 15:15:57,850] ERROR [ReplicaFetcher replicaId=0, leaderId=2, fetcherId=0] Error for partition topic-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 15:15:57,851] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition topic-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 15:16:56,520] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:16:56,523] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition topic-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 15:17:27,098] ERROR [ReplicaManager broker=2] Error while changing replica dir for partition topic-0 (kafka.server.ReplicaManager:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: Partition topic-0 doesn't exist
      [2019-11-14 15:17:27,103] ERROR [ReplicaManager broker=1] Error while changing replica dir for partition topic-0 (kafka.server.ReplicaManager:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: Partition topic-0 doesn't exist
      [2019-11-14 15:17:27,104] ERROR [ReplicaManager broker=0] Error while changing replica dir for partition topic-0 (kafka.server.ReplicaManager:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: Partition topic-0 doesn't exist
      [2019-11-14 15:17:27,148] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition topic-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 15:17:27,175] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition topic-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 15:17:35,677] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition topic-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 15:17:35,677] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:18:05,169] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-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 15:18:05,170] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:18:15,414] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-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 15:18:21,191] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition create-partitions-topic-2-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 15:18:21,497] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition create-partitions-topic-2-2 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:18:50,952] ERROR [ReplicaFetcher replicaId=0, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:18:50,953] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-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 15:19:00,326] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:19:00,327] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition topic-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 15:19:09,623] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-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 15:19:32,744] ERROR [ReplicaFetcher replicaId=1, leaderId=0, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:19:32,747] ERROR [ReplicaFetcher replicaId=1, leaderId=2, fetcherId=0] Error for partition topic-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 15:19:48,147] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition topic-1 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
      [2019-11-14 15:19:48,147] ERROR [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=0] Error for partition topic-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 15:19:55,636] ERROR [Consumer instanceId=test_instance_id, clientId=test_client_id, groupId=test_group_id] Offset commit failed on partition test_topic-1 at offset 0: Specified group generation id is not valid. (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:1108)
      [2019-11-14 15:20:01,895] ERROR [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=0] Error for partition unclean-test-topic-1-0 at offset 0 (kafka.server.ReplicaFetcherThread:76)
      org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                rsivaram Rajini Sivaram
                Reporter:
                bbejeck Bill Bejeck
                Reviewer:
                Manikumar
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: