search

confluentinc / ksql

The database purpose-built for stream processing applications.
https://ksqldb.io
Other
123 stars 1.04k forks source link

RQTT fails due to async topic deletion. #3973

Closed big-andy-coates closed 4 years ago

big-andy-coates commented 4 years ago

RQTT tests sometimes fail because a topic used in the previous test, which has been marked for deletion, hasn't yet been deleted when the next test tries to create a topic with the same name.

Unfortunately, I know of no way, except maybe checking the brokers file system), to know when a topic marked for deletion has actually been deleted. Hence there is no easy fix for this race condition.

example output from failed test run:

[2019-11-23 00:57:24,216] ERROR Exception encountered running command: Failed to create topic:test_topic. Retrying in 10 ms (io.confluent.ksql.util.RetryUtil:101)
[2019-11-23 00:57:24,217] ERROR Stack trace: java.lang.RuntimeException: Failed to create topic:test_topic
    at io.confluent.ksql.test.util.KafkaEmbedded.createTopic(KafkaEmbedded.java:174)
    at io.confluent.ksql.test.util.KafkaEmbedded.createTopic(KafkaEmbedded.java:146)
    at io.confluent.ksql.test.util.EmbeddedSingleNodeKafkaCluster.createTopic(EmbeddedSingleNodeKafkaCluster.java:275)
    at io.confluent.ksql.test.rest.RestTestExecutor.lambda$null$0(RestTestExecutor.java:114)
    at io.confluent.ksql.util.RetryUtil.retryWithBackoff(RetryUtil.java:84)
    at io.confluent.ksql.util.RetryUtil.retryWithBackoff(RetryUtil.java:57)
    at io.confluent.ksql.util.RetryUtil.retryWithBackoff(RetryUtil.java:40)
    at io.confluent.ksql.test.rest.RestTestExecutor.lambda$initializeTopics$2(RestTestExecutor.java:122)
    at com.google.common.collect.ImmutableList.forEach(ImmutableList.java:407)
    at io.confluent.ksql.test.rest.RestTestExecutor.initializeTopics(RestTestExecutor.java:113)
    at io.confluent.ksql.test.rest.RestTestExecutor.buildAndExecuteQuery(RestTestExecutor.java:95)
    at io.confluent.ksql.test.rest.RestQueryTranslationTest.shouldBuildAndExecuteQueries(RestQueryTranslationTest.java:111)
    at sun.reflect.GeneratedMethodAccessor58.invoke(Unknown Source)
    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:50)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.junit.runners.Suite.runChild(Suite.java:128)
    at org.junit.runners.Suite.runChild(Suite.java:27)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
    at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
    at io.confluent.ksql.integration.Retry$1.evaluate(Retry.java:127)
    at org.junit.rules.RunRules.evaluate(RunRules.java:20)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.junit.runners.Suite.runChild(Suite.java:128)
    at org.junit.runners.Suite.runChild(Suite.java:27)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.apache.maven.surefire.junitcore.JUnitCore.run(JUnitCore.java:55)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:137)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:107)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:83)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:75)
    at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:158)
    at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:379)
    at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:340)
    at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:125)
    at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:413)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TopicExistsException: Topic 'test_topic' already exists.
    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 io.confluent.ksql.test.util.KafkaEmbedded.createTopic(KafkaEmbedded.java:172)
    ... 58 more
Caused by: org.apache.kafka.common.errors.TopicExistsException: Topic 'test_topic' already exists.
 (io.confluent.ksql.util.RetryUtil:105)
[2019-11-23 00:57:24,231] ERROR Exception encountered running command: Failed to create topic:test_topic. Retrying in 20 ms (io.confluent.ksql.util.RetryUtil:101)
[2019-11-23 00:57:24,232] ERROR Stack trace: java.lang.RuntimeException: Failed to create topic:test_topic
    at io.confluent.ksql.test.util.KafkaEmbedded.createTopic(KafkaEmbedded.java:174)
    at io.confluent.ksql.test.util.KafkaEmbedded.createTopic(KafkaEmbedded.java:146)
    at io.confluent.ksql.test.util.EmbeddedSingleNodeKafkaCluster.createTopic(EmbeddedSingleNodeKafkaCluster.java:275)
    at io.confluent.ksql.test.rest.RestTestExecutor.lambda$null$0(RestTestExecutor.java:114)
    at io.confluent.ksql.util.RetryUtil.retryWithBackoff(RetryUtil.java:84)
    at io.confluent.ksql.util.RetryUtil.retryWithBackoff(RetryUtil.java:57)
    at io.confluent.ksql.util.RetryUtil.retryWithBackoff(RetryUtil.java:40)
    at io.confluent.ksql.test.rest.RestTestExecutor.lambda$initializeTopics$2(RestTestExecutor.java:122)
    at com.google.common.collect.ImmutableList.forEach(ImmutableList.java:407)
    at io.confluent.ksql.test.rest.RestTestExecutor.initializeTopics(RestTestExecutor.java:113)
    at io.confluent.ksql.test.rest.RestTestExecutor.buildAndExecuteQuery(RestTestExecutor.java:95)
    at io.confluent.ksql.test.rest.RestQueryTranslationTest.shouldBuildAndExecuteQueries(RestQueryTranslationTest.java:111)
    at sun.reflect.GeneratedMethodAccessor58.invoke(Unknown Source)
    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:50)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.junit.runners.Suite.runChild(Suite.java:128)
    at org.junit.runners.Suite.runChild(Suite.java:27)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
    at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
    at io.confluent.ksql.integration.Retry$1.evaluate(Retry.java:127)
    at org.junit.rules.RunRules.evaluate(RunRules.java:20)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.junit.runners.Suite.runChild(Suite.java:128)
    at org.junit.runners.Suite.runChild(Suite.java:27)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.apache.maven.surefire.junitcore.JUnitCore.run(JUnitCore.java:55)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:137)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:107)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:83)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:75)
    at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:158)
    at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:379)
    at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:340)
    at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:125)
    at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:413)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TopicExistsException: Topic 'test_topic' already exists.
    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 io.confluent.ksql.test.util.KafkaEmbedded.createTopic(KafkaEmbedded.java:172)
    ... 58 more
Caused by: org.apache.kafka.common.errors.TopicExistsException: Topic 'test_topic' already exists.
 (io.confluent.ksql.util.RetryUtil:105)
[2019-11-23 00:57:24,238] INFO Log for partition AGGREGATE-3 is renamed to /tmp/junit1133538737557353880/junit7488948375010259375/AGGREGATE-3.f53e29a1878343698708091e193e50fa-delete and is scheduled for deletion (kafka.log.LogManager:66)
[2019-11-23 00:57:24,264] ERROR Exception encountered running command: Failed to create topic:test_topic. Retrying in 40 ms (io.confluent.ksql.util.RetryUtil:101)
[2019-11-23 00:57:24,264] ERROR Stack trace: java.lang.RuntimeException: Failed to create topic:test_topic
    at io.confluent.ksql.test.util.KafkaEmbedded.createTopic(KafkaEmbedded.java:174)
    at io.confluent.ksql.test.util.KafkaEmbedded.createTopic(KafkaEmbedded.java:146)
    at io.confluent.ksql.test.util.EmbeddedSingleNodeKafkaCluster.createTopic(EmbeddedSingleNodeKafkaCluster.java:275)
    at io.confluent.ksql.test.rest.RestTestExecutor.lambda$null$0(RestTestExecutor.java:114)
    at io.confluent.ksql.util.RetryUtil.retryWithBackoff(RetryUtil.java:84)
    at io.confluent.ksql.util.RetryUtil.retryWithBackoff(RetryUtil.java:57)
    at io.confluent.ksql.util.RetryUtil.retryWithBackoff(RetryUtil.java:40)
    at io.confluent.ksql.test.rest.RestTestExecutor.lambda$initializeTopics$2(RestTestExecutor.java:122)
    at com.google.common.collect.ImmutableList.forEach(ImmutableList.java:407)
    at io.confluent.ksql.test.rest.RestTestExecutor.initializeTopics(RestTestExecutor.java:113)
    at io.confluent.ksql.test.rest.RestTestExecutor.buildAndExecuteQuery(RestTestExecutor.java:95)
    at io.confluent.ksql.test.rest.RestQueryTranslationTest.shouldBuildAndExecuteQueries(RestQueryTranslationTest.java:111)
    at sun.reflect.GeneratedMethodAccessor58.invoke(Unknown Source)
    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:50)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
    at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.junit.runners.Suite.runChild(Suite.java:128)
    at org.junit.runners.Suite.runChild(Suite.java:27)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
    at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:48)
    at io.confluent.ksql.integration.Retry$1.evaluate(Retry.java:127)
    at org.junit.rules.RunRules.evaluate(RunRules.java:20)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.junit.runners.Suite.runChild(Suite.java:128)
    at org.junit.runners.Suite.runChild(Suite.java:27)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.apache.maven.surefire.junitcore.JUnitCore.run(JUnitCore.java:55)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.createRequestAndRun(JUnitCoreWrapper.java:137)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.executeEager(JUnitCoreWrapper.java:107)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:83)
    at org.apache.maven.surefire.junitcore.JUnitCoreWrapper.execute(JUnitCoreWrapper.java:75)
    at org.apache.maven.surefire.junitcore.JUnitCoreProvider.invoke(JUnitCoreProvider.java:158)
    at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:379)
    at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:340)
    at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:125)
    at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:413)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TopicExistsException: Topic 'test_topic' already exists.
    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 io.confluent.ksql.test.util.KafkaEmbedded.createTopic(KafkaEmbedded.java:172)
    ... 58 more
Caused by: org.apache.kafka.common.errors.TopicExistsException: Topic 'test_topic' already exists.
 (io.confluent.ksql.util.RetryUtil:105)
[2019-11-23 00:57:24,273] INFO Log for partition AGGREGATE-2 is renamed to /tmp/junit1133538737557353880/junit7488948375010259375/AGGREGATE-2.eb039aa34a4046afb638e241dc94ea46-delete and is scheduled for deletion (kafka.log.LogManager:66)
[2019-11-23 00:57:24,293] INFO [Topic Deletion Manager 0] Deletion of topic test_topic successfully completed (kafka.controller.TopicDeletionManager:66)
[2019-11-23 00:57:24,294] INFO [Controller id=0] New topics: [Set()], deleted topics: [Set()], new partition replica assignment [Map()] (kafka.controller.KafkaController:66)
[2019-11-23 00:57:24,294] INFO [Controller id=0] Starting topic deletion for topics AGGREGATE (kafka.controller.KafkaController:66)
[2019-11-23 00:57:24,294] INFO [Topic Deletion Manager 0] Handling deletion for topics AGGREGATE (kafka.controller.TopicDeletionManager:66)
[2019-11-23 00:57:24,308] INFO Creating topic test_topic with configuration {} and initial partition assignment Map(2 -> ArrayBuffer(0), 1 -> ArrayBuffer(0), 3 -> ArrayBuffer(0), 0 -> ArrayBuffer(0)) (kafka.zk.AdminZkClient:66)
[2019-11-23 00:57:24,321] INFO Log for partition AGGREGATE-0 is renamed to /tmp/junit1133538737557353880/junit7488948375010259375/AGGREGATE-0.9c07b3299e514915880689ad58efc5cc-delete and is scheduled for deletion (kafka.log.LogManager:66)
[2019-11-23 00:57:24,343] INFO [Controller id=0] New topics: [Set(test_topic)], deleted topics: [Set()], new partition replica assignment [Map(test_topic-2 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), test_topic-1 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), test_topic-0 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=), test_topic-3 -> ReplicaAssignment(replicas=0, addingReplicas=, removingReplicas=))] (kafka.controller.KafkaController:66)
[2019-11-23 00:57:24,343] INFO [Controller id=0] New partition creation callback for test_topic-2,test_topic-1,test_topic-0,test_topic-3 (kafka.controller.KafkaController:66)
[2019-11-23 00:57:24,387] INFO Log for partition AGGREGATE-1 is renamed to /tmp/junit1133538737557353880/junit7488948375010259375/AGGREGATE-1.6b812862cf674171a97b05dd0d1e76c4-delete and is scheduled for deletion (kafka.log.LogManager:66)
[2019-11-23 00:57:24,473] INFO [Topic Deletion Manager 0] Handling deletion for topics AGGREGATE (kafka.controller.TopicDeletionManager:66)
[2019-11-23 00:57:24,474] INFO [ReplicaFetcherManager on broker 0] Removed fetcher for partitions Set(test_topic-2, test_topic-3, test_topic-0, test_topic-1) (kafka.server.ReplicaFetcherManager:66)
[2019-11-23 00:57:24,475] INFO [Log partition=test_topic-2, dir=/tmp/junit1133538737557353880/junit7488948375010259375] Loading producer state till offset 0 with message format version 2 (kafka.log.Log:66)
[2019-11-23 00:57:24,476] INFO [Log partition=test_topic-2, dir=/tmp/junit1133538737557353880/junit7488948375010259375] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log:66)
[2019-11-23 00:57:24,476] INFO Created log for partition test_topic-2 in /tmp/junit1133538737557353880/junit7488948375010259375/test_topic-2 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> -1, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 9223372036854775807, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 100000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager:66)
[2019-11-23 00:57:24,476] INFO [Partition test_topic-2 broker=0] Log loaded for partition test_topic-2 with initial high watermark 0 (kafka.cluster.Partition:66)
[2019-11-23 00:57:24,476] INFO [Partition test_topic-2 broker=0] test_topic-2 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition:66)
[2019-11-23 00:57:24,535] INFO [Log partition=test_topic-3, dir=/tmp/junit1133538737557353880/junit7488948375010259375] Loading producer state till offset 0 with message format version 2 (kafka.log.Log:66)
[2019-11-23 00:57:24,536] INFO [Log partition=test_topic-3, dir=/tmp/junit1133538737557353880/junit7488948375010259375] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log:66)
[2019-11-23 00:57:24,536] INFO Created log for partition test_topic-3 in /tmp/junit1133538737557353880/junit7488948375010259375/test_topic-3 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> -1, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 9223372036854775807, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 100000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager:66)
[2019-11-23 00:57:24,536] INFO [Partition test_topic-3 broker=0] Log loaded for partition test_topic-3 with initial high watermark 0 (kafka.cluster.Partition:66)
[2019-11-23 00:57:24,536] INFO [Partition test_topic-3 broker=0] test_topic-3 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition:66)
[2019-11-23 00:57:24,609] INFO [Log partition=test_topic-0, dir=/tmp/junit1133538737557353880/junit7488948375010259375] Loading producer state till offset 0 with message format version 2 (kafka.log.Log:66)
[2019-11-23 00:57:24,609] INFO [Log partition=test_topic-0, dir=/tmp/junit1133538737557353880/junit7488948375010259375] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 19 ms (kafka.log.Log:66)
[2019-11-23 00:57:24,610] INFO Created log for partition test_topic-0 in /tmp/junit1133538737557353880/junit7488948375010259375/test_topic-0 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> -1, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 9223372036854775807, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 100000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager:66)
[2019-11-23 00:57:24,610] INFO [Partition test_topic-0 broker=0] Log loaded for partition test_topic-0 with initial high watermark 0 (kafka.cluster.Partition:66)
[2019-11-23 00:57:24,610] INFO [Partition test_topic-0 broker=0] test_topic-0 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition:66)
[2019-11-23 00:57:24,668] INFO [Log partition=test_topic-1, dir=/tmp/junit1133538737557353880/junit7488948375010259375] Loading producer state till offset 0 with message format version 2 (kafka.log.Log:66)
[2019-11-23 00:57:24,669] INFO [Log partition=test_topic-1, dir=/tmp/junit1133538737557353880/junit7488948375010259375] Completed load of log with 1 segments, log start offset 0 and log end offset 0 in 1 ms (kafka.log.Log:66)
[2019-11-23 00:57:24,669] INFO Created log for partition test_topic-1 in /tmp/junit1133538737557353880/junit7488948375010259375/test_topic-1 with properties {compression.type -> producer, message.downconversion.enable -> true, min.insync.replicas -> 1, segment.jitter.ms -> 0, cleanup.policy -> [delete], flush.ms -> 9223372036854775807, segment.bytes -> 1073741824, retention.ms -> -1, flush.messages -> 9223372036854775807, message.format.version -> 2.4-IV1, file.delete.delay.ms -> 9223372036854775807, max.compaction.lag.ms -> 9223372036854775807, max.message.bytes -> 100000, min.compaction.lag.ms -> 0, message.timestamp.type -> CreateTime, preallocate -> false, min.cleanable.dirty.ratio -> 0.5, index.interval.bytes -> 4096, unclean.leader.election.enable -> false, retention.bytes -> -1, delete.retention.ms -> 86400000, segment.ms -> 604800000, message.timestamp.difference.max.ms -> 9223372036854775807, segment.index.bytes -> 10485760}. (kafka.log.LogManager:66)
[2019-11-23 00:57:24,669] INFO [Partition test_topic-1 broker=0] Log loaded for partition test_topic-1 with initial high watermark 0 (kafka.cluster.Partition:66)
[2019-11-23 00:57:24,669] INFO [Partition test_topic-1 broker=0] test_topic-1 starts at Leader Epoch 0 from offset 0. Previous Leader Epoch was: -1 (kafka.cluster.Partition:66)
[2019-11-23 00:57:24,712] INFO Received: KsqlRequest{ksql='CREATE STREAM INPUT (IGNORED INT) WITH (kafka_topic='test_topic', value_format='JSON');
CREATE TABLE AGGREGATE AS SELECT COUNT(1) AS COUNT FROM INPUT GROUP BY ROWKEY;', streamsProperties={}, commandSequenceNumber=Optional.empty} (io.confluent.ksql.rest.server.resources.KsqlResource:203)
[2019-11-23 00:57:24,717] INFO Creating topic 'AGGREGATE' (ONLY VALIDATE) (io.confluent.ksql.services.KafkaTopicClient:108)
[2019-11-23 00:57:24,730] INFO Retrying request. Retry no: 0 (io.confluent.ksql.util.ExecutorUtil:78)
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
    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 io.confluent.ksql.services.KafkaTopicClientImpl.lambda$describeTopics$3(KafkaTopicClientImpl.java:193)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:73)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:59)
    at io.confluent.ksql.services.KafkaTopicClientImpl.describeTopics(KafkaTopicClientImpl.java:189)
    at io.confluent.ksql.services.KafkaTopicClient.describeTopic(KafkaTopicClient.java:159)
    at io.confluent.ksql.services.KafkaTopicClientImpl.validateTopicProperties(KafkaTopicClientImpl.java:335)
    at io.confluent.ksql.services.KafkaTopicClientImpl.createTopic(KafkaTopicClientImpl.java:128)
    at io.confluent.ksql.services.KafkaTopicClient.validateCreateTopic(KafkaTopicClient.java:49)
    at io.confluent.ksql.services.SandboxedKafkaTopicClient.createTopic(SandboxedKafkaTopicClient.java:103)
    at sun.reflect.GeneratedMethodAccessor48.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at io.confluent.ksql.util.LimitedProxyBuilder.lambda$buildForwader$8(LimitedProxyBuilder.java:234)
    at io.confluent.ksql.util.LimitedProxyBuilder$SandboxProxy.invoke(LimitedProxyBuilder.java:312)
    at com.sun.proxy.$Proxy97.createTopic(Unknown Source)
    at io.confluent.ksql.topic.TopicCreateInjector.createTopic(TopicCreateInjector.java:186)
    at io.confluent.ksql.topic.TopicCreateInjector.injectForCreateAsSelect(TopicCreateInjector.java:163)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:85)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:75)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:145)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:113)
    at io.confluent.ksql.rest.server.resources.KsqlResource.handleKsqlStatements(KsqlResource.java:216)
    at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
    at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:176)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:469)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:391)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:80)
    at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:253)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
    at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
    at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:232)
    at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:679)
    at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:392)
    at org.glassfish.jersey.servlet.ServletContainer.serviceImpl(ServletContainer.java:385)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:560)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:501)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:438)
    at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1591)
    at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:542)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1581)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1307)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
    at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:482)
    at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1549)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
    at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1204)
    at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:173)
    at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:221)
    at org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:772)
    at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
    at org.eclipse.jetty.server.Server.handle(Server.java:494)
    at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:374)
    at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:268)
    at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
    at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)
    at org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129)
    at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:367)
    at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:782)
    at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918)
    at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2019-11-23 00:57:24,853] INFO [Topic Deletion Manager 0] Deletion of topic AGGREGATE successfully completed (kafka.controller.TopicDeletionManager:66)
[2019-11-23 00:57:24,853] INFO [Controller id=0] New topics: [Set()], deleted topics: [Set()], new partition replica assignment [Map()] (kafka.controller.KafkaController:66)
[2019-11-23 00:57:25,118] INFO [GroupCoordinator 0]: Member _confluent-ksql-default_query_CTAS_AGGREGATE_384-2cbf061b-7b17-4922-8ed1-da7424c0c7f8-StreamThread-1-consumer-2855a532-9e37-4699-bf3c-98939eaa764f in group _confluent-ksql-default_query_CTAS_AGGREGATE_384 has failed, removing it from the group (kafka.coordinator.group.GroupCoordinator:66)
[2019-11-23 00:57:25,118] INFO [GroupCoordinator 0]: Preparing to rebalance group _confluent-ksql-default_query_CTAS_AGGREGATE_384 in state PreparingRebalance with old generation 1 (__consumer_offsets-0) (reason: removing member _confluent-ksql-default_query_CTAS_AGGREGATE_384-2cbf061b-7b17-4922-8ed1-da7424c0c7f8-StreamThread-1-consumer-2855a532-9e37-4699-bf3c-98939eaa764f on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator:66)
[2019-11-23 00:57:25,119] INFO [GroupCoordinator 0]: Group _confluent-ksql-default_query_CTAS_AGGREGATE_384 with generation 2 is now empty (__consumer_offsets-0) (kafka.coordinator.group.GroupCoordinator:66)
[2019-11-23 00:57:25,231] INFO Retrying request. Retry no: 1 (io.confluent.ksql.util.ExecutorUtil:78)
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
    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 io.confluent.ksql.services.KafkaTopicClientImpl.lambda$describeTopics$3(KafkaTopicClientImpl.java:193)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:73)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:59)
    at io.confluent.ksql.services.KafkaTopicClientImpl.describeTopics(KafkaTopicClientImpl.java:189)
    at io.confluent.ksql.services.KafkaTopicClient.describeTopic(KafkaTopicClient.java:159)
    at io.confluent.ksql.services.KafkaTopicClientImpl.validateTopicProperties(KafkaTopicClientImpl.java:335)
    at io.confluent.ksql.services.KafkaTopicClientImpl.createTopic(KafkaTopicClientImpl.java:128)
    at io.confluent.ksql.services.KafkaTopicClient.validateCreateTopic(KafkaTopicClient.java:49)
    at io.confluent.ksql.services.SandboxedKafkaTopicClient.createTopic(SandboxedKafkaTopicClient.java:103)
    at sun.reflect.GeneratedMethodAccessor48.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at io.confluent.ksql.util.LimitedProxyBuilder.lambda$buildForwader$8(LimitedProxyBuilder.java:234)
    at io.confluent.ksql.util.LimitedProxyBuilder$SandboxProxy.invoke(LimitedProxyBuilder.java:312)
    at com.sun.proxy.$Proxy97.createTopic(Unknown Source)
    at io.confluent.ksql.topic.TopicCreateInjector.createTopic(TopicCreateInjector.java:186)
    at io.confluent.ksql.topic.TopicCreateInjector.injectForCreateAsSelect(TopicCreateInjector.java:163)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:85)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:75)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:145)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:113)
    at io.confluent.ksql.rest.server.resources.KsqlResource.handleKsqlStatements(KsqlResource.java:216)
    at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
    at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:176)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:469)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:391)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:80)
    at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:253)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
    at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
    at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:232)
    at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:679)
    at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:392)
    at org.glassfish.jersey.servlet.ServletContainer.serviceImpl(ServletContainer.java:385)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:560)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:501)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:438)
    at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1591)
    at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:542)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1581)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1307)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
    at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:482)
    at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1549)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
    at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1204)
    at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:173)
    at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:221)
    at org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:772)
    at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
    at org.eclipse.jetty.server.Server.handle(Server.java:494)
    at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:374)
    at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:268)
    at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
    at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)
    at org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129)
    at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:367)
    at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:782)
    at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918)
    at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2019-11-23 00:57:25,733] INFO Retrying request. Retry no: 2 (io.confluent.ksql.util.ExecutorUtil:78)
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
    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 io.confluent.ksql.services.KafkaTopicClientImpl.lambda$describeTopics$3(KafkaTopicClientImpl.java:193)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:73)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:59)
    at io.confluent.ksql.services.KafkaTopicClientImpl.describeTopics(KafkaTopicClientImpl.java:189)
    at io.confluent.ksql.services.KafkaTopicClient.describeTopic(KafkaTopicClient.java:159)
    at io.confluent.ksql.services.KafkaTopicClientImpl.validateTopicProperties(KafkaTopicClientImpl.java:335)
    at io.confluent.ksql.services.KafkaTopicClientImpl.createTopic(KafkaTopicClientImpl.java:128)
    at io.confluent.ksql.services.KafkaTopicClient.validateCreateTopic(KafkaTopicClient.java:49)
    at io.confluent.ksql.services.SandboxedKafkaTopicClient.createTopic(SandboxedKafkaTopicClient.java:103)
    at sun.reflect.GeneratedMethodAccessor48.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at io.confluent.ksql.util.LimitedProxyBuilder.lambda$buildForwader$8(LimitedProxyBuilder.java:234)
    at io.confluent.ksql.util.LimitedProxyBuilder$SandboxProxy.invoke(LimitedProxyBuilder.java:312)
    at com.sun.proxy.$Proxy97.createTopic(Unknown Source)
    at io.confluent.ksql.topic.TopicCreateInjector.createTopic(TopicCreateInjector.java:186)
    at io.confluent.ksql.topic.TopicCreateInjector.injectForCreateAsSelect(TopicCreateInjector.java:163)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:85)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:75)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:145)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:113)
    at io.confluent.ksql.rest.server.resources.KsqlResource.handleKsqlStatements(KsqlResource.java:216)
    at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
    at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:176)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:469)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:391)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:80)
    at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:253)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
    at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
    at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:232)
    at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:679)
    at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:392)
    at org.glassfish.jersey.servlet.ServletContainer.serviceImpl(ServletContainer.java:385)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:560)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:501)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:438)
    at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1591)
    at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:542)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1581)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1307)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
    at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:482)
    at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1549)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
    at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1204)
    at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:173)
    at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:221)
    at org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:772)
    at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
    at org.eclipse.jetty.server.Server.handle(Server.java:494)
    at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:374)
    at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:268)
    at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
    at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)
    at org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129)
    at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:367)
    at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:782)
    at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918)
    at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2019-11-23 00:57:26,235] INFO Retrying request. Retry no: 3 (io.confluent.ksql.util.ExecutorUtil:78)
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
    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 io.confluent.ksql.services.KafkaTopicClientImpl.lambda$describeTopics$3(KafkaTopicClientImpl.java:193)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:73)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:59)
    at io.confluent.ksql.services.KafkaTopicClientImpl.describeTopics(KafkaTopicClientImpl.java:189)
    at io.confluent.ksql.services.KafkaTopicClient.describeTopic(KafkaTopicClient.java:159)
    at io.confluent.ksql.services.KafkaTopicClientImpl.validateTopicProperties(KafkaTopicClientImpl.java:335)
    at io.confluent.ksql.services.KafkaTopicClientImpl.createTopic(KafkaTopicClientImpl.java:128)
    at io.confluent.ksql.services.KafkaTopicClient.validateCreateTopic(KafkaTopicClient.java:49)
    at io.confluent.ksql.services.SandboxedKafkaTopicClient.createTopic(SandboxedKafkaTopicClient.java:103)
    at sun.reflect.GeneratedMethodAccessor48.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at io.confluent.ksql.util.LimitedProxyBuilder.lambda$buildForwader$8(LimitedProxyBuilder.java:234)
    at io.confluent.ksql.util.LimitedProxyBuilder$SandboxProxy.invoke(LimitedProxyBuilder.java:312)
    at com.sun.proxy.$Proxy97.createTopic(Unknown Source)
    at io.confluent.ksql.topic.TopicCreateInjector.createTopic(TopicCreateInjector.java:186)
    at io.confluent.ksql.topic.TopicCreateInjector.injectForCreateAsSelect(TopicCreateInjector.java:163)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:85)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:75)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:145)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:113)
    at io.confluent.ksql.rest.server.resources.KsqlResource.handleKsqlStatements(KsqlResource.java:216)
    at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
    at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:176)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:469)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:391)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:80)
    at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:253)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
    at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
    at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:232)
    at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:679)
    at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:392)
    at org.glassfish.jersey.servlet.ServletContainer.serviceImpl(ServletContainer.java:385)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:560)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:501)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:438)
    at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1591)
    at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:542)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1581)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1307)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
    at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:482)
    at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1549)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
    at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1204)
    at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:173)
    at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:221)
    at org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:772)
    at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
    at org.eclipse.jetty.server.Server.handle(Server.java:494)
    at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:374)
    at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:268)
    at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
    at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)
    at org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129)
    at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:367)
    at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:782)
    at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918)
    at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2019-11-23 00:57:26,736] INFO Retrying request. Retry no: 4 (io.confluent.ksql.util.ExecutorUtil:78)
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
    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 io.confluent.ksql.services.KafkaTopicClientImpl.lambda$describeTopics$3(KafkaTopicClientImpl.java:193)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:73)
    at io.confluent.ksql.util.ExecutorUtil.executeWithRetries(ExecutorUtil.java:59)
    at io.confluent.ksql.services.KafkaTopicClientImpl.describeTopics(KafkaTopicClientImpl.java:189)
    at io.confluent.ksql.services.KafkaTopicClient.describeTopic(KafkaTopicClient.java:159)
    at io.confluent.ksql.services.KafkaTopicClientImpl.validateTopicProperties(KafkaTopicClientImpl.java:335)
    at io.confluent.ksql.services.KafkaTopicClientImpl.createTopic(KafkaTopicClientImpl.java:128)
    at io.confluent.ksql.services.KafkaTopicClient.validateCreateTopic(KafkaTopicClient.java:49)
    at io.confluent.ksql.services.SandboxedKafkaTopicClient.createTopic(SandboxedKafkaTopicClient.java:103)
    at sun.reflect.GeneratedMethodAccessor48.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at io.confluent.ksql.util.LimitedProxyBuilder.lambda$buildForwader$8(LimitedProxyBuilder.java:234)
    at io.confluent.ksql.util.LimitedProxyBuilder$SandboxProxy.invoke(LimitedProxyBuilder.java:312)
    at com.sun.proxy.$Proxy97.createTopic(Unknown Source)
    at io.confluent.ksql.topic.TopicCreateInjector.createTopic(TopicCreateInjector.java:186)
    at io.confluent.ksql.topic.TopicCreateInjector.injectForCreateAsSelect(TopicCreateInjector.java:163)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:85)
    at io.confluent.ksql.topic.TopicCreateInjector.inject(TopicCreateInjector.java:75)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.statement.InjectorChain.inject(InjectorChain.java:42)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:145)
    at io.confluent.ksql.rest.server.validation.RequestValidator.validate(RequestValidator.java:113)
    at io.confluent.ksql.rest.server.resources.KsqlResource.handleKsqlStatements(KsqlResource.java:216)
    at sun.reflect.GeneratedMethodAccessor40.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.glassfish.jersey.server.model.internal.ResourceMethodInvocationHandlerFactory.lambda$static$0(ResourceMethodInvocationHandlerFactory.java:52)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher$1.run(AbstractJavaResourceMethodDispatcher.java:124)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.invoke(AbstractJavaResourceMethodDispatcher.java:167)
    at org.glassfish.jersey.server.model.internal.JavaResourceMethodDispatcherProvider$ResponseOutInvoker.doDispatch(JavaResourceMethodDispatcherProvider.java:176)
    at org.glassfish.jersey.server.model.internal.AbstractJavaResourceMethodDispatcher.dispatch(AbstractJavaResourceMethodDispatcher.java:79)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.invoke(ResourceMethodInvoker.java:469)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:391)
    at org.glassfish.jersey.server.model.ResourceMethodInvoker.apply(ResourceMethodInvoker.java:80)
    at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:253)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248)
    at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:292)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:274)
    at org.glassfish.jersey.internal.Errors.process(Errors.java:244)
    at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265)
    at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:232)
    at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:679)
    at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:392)
    at org.glassfish.jersey.servlet.ServletContainer.serviceImpl(ServletContainer.java:385)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:560)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:501)
    at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:438)
    at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1591)
    at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:542)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1581)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233)
    at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1307)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188)
    at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:482)
    at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1549)
    at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186)
    at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1204)
    at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146)
    at org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:173)
    at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:221)
    at org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:772)
    at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127)
    at org.eclipse.jetty.server.Server.handle(Server.java:494)
    at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:374)
    at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:268)
    at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311)
    at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103)
    at org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171)
    at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129)
    at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:367)
    at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:782)
    at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:918)
    at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition.
[2019-11-23 00:57:26,738] INFO 127.0.0.1 - - [23/Nov/2019:00:57:24 +0000] "POST /ksql HTTP/1.1" 500 7093  2026 (io.confluent.rest-utils.requests:62)
[2019-11-23 00:57:26,748] INFO Received: KsqlRequest{ksql='SHOW QUERIES;', streamsProperties={}, commandSequenceNumber=Optional.empty} (io.confluent.ksql.rest.server.resources.KsqlResource:203)
[2019-11-23 00:57:26,749] INFO 127.0.0.1 - - [23/Nov/2019:00:57:26 +0000] "POST /ksql HTTP/1.1" 200 80  1 (io.confluent.rest-utils.requests:62)
[2019-11-23 00:57:26,758] INFO Received: KsqlRequest{ksql='SHOW STREAMS;', streamsProperties={}, commandSequenceNumber=Optional.empty} (io.confluent.ksql.rest.server.resources.KsqlResource:203)
[2019-11-23 00:57:26,759] INFO 127.0.0.1 - - [23/Nov/2019:00:57:26 +0000] "POST /ksql HTTP/1.1" 200 148  1 (io.confluent.rest-utils.requests:62)
[2019-11-23 00:57:26,760] INFO Received: KsqlRequest{ksql='DROP STREAM test;', streamsProperties={}, commandSequenceNumber=Optional.empty} (io.confluent.ksql.rest.server.resources.KsqlResource:203)
[2019-11-23 00:57:26,761] INFO [Producer clientId=producer-default_, transactionalId=default_] Instantiated a transactional producer. (org.apache.kafka.clients.producer.KafkaProducer:541)
[2019-11-23 00:57:26,764] INFO [Producer clientId=producer-default_, transactionalId=default_] Overriding the default retries config to the recommended value of 2147483647 since the idempotent producer is enabled. (org.apache.kafka.clients.producer.KafkaProducer:557)
[2019-11-23 00:57:26,765] WARN The configuration 'ksql.streams.cache.max.bytes.buffering' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2019-11-23 00:57:26,765] WARN The configuration 'ksql.streams.commit.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2019-11-23 00:57:26,765] WARN The configuration 'listeners' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2019-11-23 00:57:26,765] WARN The configuration 'ksql.streams.num.stream.threads' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2019-11-23 00:57:26,765] WARN The configuration 'ksql.streams.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2019-11-23 00:57:26,765] WARN The configuration 'ksql.udfs.enabled' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2019-11-23 00:57:26,765] WARN The configuration 'ksql.query.pull.skip.access.validator' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2019-11-23 00:57:26,765] WARN The configuration 'ksql.streams.application.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig:355)
[2019-11-23 00:57:26,766] INFO [Producer clientId=producer-default_, transactionalId=default_] ProducerId set to -1 with epoch -1 (org.apache.kafka.clients.producer.internals.TransactionManager:450)
[2019-11-23 00:57:26,869] INFO [Producer clientId=producer-default_, transactionalId=default_] Cluster ID: N-NSL4ypThOYXb_sKV9lew (org.apache.kafka.clients.Metadata:261)
[2019-11-23 00:57:26,869] INFO [TransactionCoordinator id=0] Initialized transactionalId default_ with producerId 0 and producer epoch 221 on partition __transaction_state-44 (kafka.coordinator.transaction.TransactionCoordinator:66)
[2019-11-23 00:57:26,869] INFO [Producer clientId=producer-default_, transactionalId=default_] ProducerId set to 0 with epoch 221 (org.apache.kafka.clients.producer.internals.TransactionManager:450)
[2019-11-23 00:57:26,873] WARN The configuration 'ksql.streams.cache.max.bytes.buffering' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2019-11-23 00:57:26,873] WARN The configuration 'ksql.streams.commit.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2019-11-23 00:57:26,874] WARN The configuration 'listeners' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2019-11-23 00:57:26,874] WARN The configuration 'ksql.streams.num.stream.threads' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2019-11-23 00:57:26,874] WARN The configuration 'ksql.streams.auto.offset.reset' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2019-11-23 00:57:26,874] WARN The configuration 'ksql.udfs.enabled' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2019-11-23 00:57:26,874] WARN The configuration 'ksql.query.pull.skip.access.validator' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2019-11-23 00:57:26,874] WARN The configuration 'ksql.streams.application.id' was supplied but isn't a known config. (org.apache.kafka.clients.consumer.ConsumerConfig:355)
[2019-11-23 00:57:26,875] INFO [Consumer clientId=consumer-243, groupId=null] Subscribed to partition(s): _confluent-ksql-default__command_topic-0 (org.apache.kafka.clients.consumer.KafkaConsumer:1126)
[2019-11-23 00:57:26,877] INFO [Consumer clientId=consumer-243, groupId=null] Cluster ID: N-NSL4ypThOYXb_sKV9lew (org.apache.kafka.clients.Metadata:261)
[2019-11-23 00:57:26,890] INFO Executing statement: DROP STREAM test; (io.confluent.ksql.rest.server.computation.CommandRunner:166)
[2019-11-23 00:57:26,891] INFO Executed statement: DROP STREAM test; (io.confluent.ksql.rest.server.computation.CommandRunner:173)
[2019-11-23 00:57:26,891] INFO [Producer clientId=producer-default_, transactionalId=default_] Closing the Kafka producer with timeoutMillis = 9223372036854775807 ms. (org.apache.kafka.clients.producer.KafkaProducer:1183)
[2019-11-23 00:57:26,894] INFO 127.0.0.1 - - [23/Nov/2019:00:57:26 +0000] "POST /ksql HTTP/1.1" 200 215  134 (io.confluent.rest-utils.requests:62)
[2019-11-23 00:57:26,895] INFO Received: KsqlRequest{ksql='SHOW TABLES;', streamsProperties={}, commandSequenceNumber=Optional.empty} (io.confluent.ksql.rest.server.resources.KsqlResource:203)
[2019-11-23 00:57:26,896] INFO 127.0.0.1 - - [23/Nov/2019:00:57:26 +0000] "POST /ksql HTTP/1.1" 200 77  2 (io.confluent.rest-utils.requests:62)
[2019-11-23 00:57:26,922] INFO [Controller id=0] Starting topic deletion for topics test_topic (kafka.controller.KafkaController:66)
[2019-11-23 00:57:26,922] INFO [Topic Deletion Manager 0] Handling deletion for topics test_topic (kafka.controller.TopicDeletionManager:66)
[2019-11-23 00:57:26,922] INFO [Topic Deletion Manager 0] Deletion of topic test_topic (re)started (kafka.controller.TopicDeletionManager:66)
[2019-11-23 00:57:26,922] INFO [Topic Deletion Manager 0] Topic deletion callback for test_topic (kafka.controller.TopicDeletionManager:66)
[2019-11-23 00:57:26,923] INFO [Topic Deletion Manager 0] Partition deletion callback for test_topic-2,test_topic-1,test_topic-3,test_topic-0 (kafka.controller.TopicDeletionManager:66)
[2019-11-23 00:57:26,923] INFO [GroupMetadataManager brokerId=0] Group _confluent-ksql-default_query_CTAS_AGGREGATE_384 transitioned to Dead in generation 2 (kafka.coordinator.group.GroupMetadataManager:66)
[2019-11-23 00:57:26,924] INFO [GroupCoordinator 0]: Removed 0 offsets associated with deleted partitions: test_topic-1, test_topic-3, test_topic-0, test_topic-2. (kafka.coordinator.group.GroupCoordinator:66)
big-andy-coates commented 4 years ago

Other potential fixes: