[ 
https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15826752#comment-15826752
 ] 

Guozhang Wang commented on KAFKA-3896:
--------------------------------------

Another instance: 
https://builds.apache.org/job/kafka-pr-jdk7-scala2.10/929/testReport/junit/org.apache.kafka.streams.integration/KStreamRepartitionJoinTest/shouldCorrectlyRepartitionOnJoinOperations_1_/

{code}
Stacktrace

java.lang.AssertionError: Condition not met within timeout 60000. Did not 
receive 5 number of records
        at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:259)
        at 
org.apache.kafka.streams.integration.utils.IntegrationTestUtils.waitUntilMinValuesRecordsReceived(IntegrationTestUtils.java:259)
        at 
org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.receiveMessages(KStreamRepartitionJoinTest.java:381)
        at 
org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.verifyCorrectOutput(KStreamRepartitionJoinTest.java:291)
        at 
org.apache.kafka.streams.integration.KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations(KStreamRepartitionJoinTest.java:139)
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:606)
        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.RunBefores.evaluate(RunBefores.java:26)
        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.RunRules.evaluate(RunRules.java:20)
        at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
        at 
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:114)
        at 
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:57)
        at 
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:66)
        at 
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
        at sun.reflect.GeneratedMethodAccessor8.invoke(Unknown Source)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:606)
        at 
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
        at 
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
        at 
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
        at 
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
        at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
        at 
org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:109)
        at sun.reflect.GeneratedMethodAccessor7.invoke(Unknown Source)
        at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:606)
        at 
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
        at 
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
        at 
org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:377)
        at 
org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:54)
        at 
org.gradle.internal.concurrent.StoppableExecutorImpl$1.run(StoppableExecutorImpl.java:40)
        at 
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
        at 
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
        at java.lang.Thread.run(Thread.java:745)
Standard Output

[2017-01-17 15:43:35,065] ERROR ZKShutdownHandler is not registered, so 
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state 
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
[2017-01-17 15:43:35,892] WARN No meta.properties file under dir 
/tmp/junit6169349685165893129/junit8289414827978962454/meta.properties 
(kafka.server.BrokerMetadataCheckpoint:85)
[2017-01-17 15:43:36,228] WARN No meta.properties file under dir 
/tmp/junit6169349685165893129/junit8289414827978962454/meta.properties 
(kafka.server.BrokerMetadataCheckpoint:85)
[2017-01-17 15:43:36,286] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:43:36,874] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:43:37,481] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:43:40,856] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:43:41,581] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:43:42,673] WARN Error while fetching metadata with correlation 
id 2 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:42,673] WARN Error while fetching metadata with correlation 
id 2 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:42,678] WARN Error while fetching metadata with correlation 
id 2 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:42,860] WARN Error while fetching metadata with correlation 
id 4 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:42,862] WARN Error while fetching metadata with correlation 
id 4 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:42,863] WARN Error while fetching metadata with correlation 
id 4 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:42,964] WARN Error while fetching metadata with correlation 
id 6 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:42,964] WARN Error while fetching metadata with correlation 
id 6 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:42,967] WARN Error while fetching metadata with correlation 
id 6 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,067] WARN Error while fetching metadata with correlation 
id 8 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,068] WARN Error while fetching metadata with correlation 
id 8 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,071] WARN Error while fetching metadata with correlation 
id 8 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,171] WARN Error while fetching metadata with correlation 
id 10 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,171] WARN Error while fetching metadata with correlation 
id 10 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,175] WARN Error while fetching metadata with correlation 
id 10 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,275] WARN Error while fetching metadata with correlation 
id 12 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,291] WARN Error while fetching metadata with correlation 
id 12 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,291] WARN Error while fetching metadata with correlation 
id 12 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,380] WARN Error while fetching metadata with correlation 
id 14 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,395] WARN Error while fetching metadata with correlation 
id 14 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,396] WARN Error while fetching metadata with correlation 
id 14 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,483] WARN Error while fetching metadata with correlation 
id 16 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,502] WARN Error while fetching metadata with correlation 
id 16 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,505] WARN Error while fetching metadata with correlation 
id 16 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,683] WARN Error while fetching metadata with correlation 
id 18 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,688] WARN Error while fetching metadata with correlation 
id 18 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,690] WARN Error while fetching metadata with correlation 
id 18 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,833] WARN Error while fetching metadata with correlation 
id 20 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,834] WARN Error while fetching metadata with correlation 
id 20 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,835] WARN Error while fetching metadata with correlation 
id 20 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,938] WARN Error while fetching metadata with correlation 
id 22 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,941] WARN Error while fetching metadata with correlation 
id 22 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:43,948] WARN Error while fetching metadata with correlation 
id 22 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:44,041] WARN Error while fetching metadata with correlation 
id 24 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:44,043] WARN Error while fetchi
...[truncated 148926 chars]...
on=UNKNOWN_TOPIC_OR_PARTITION, 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,490] WARN Error while fetching metadata with correlation 
id 98 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,490] WARN Error while fetching metadata with correlation 
id 96 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,602] WARN Error while fetching metadata with correlation 
id 100 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,602] WARN Error while fetching metadata with correlation 
id 98 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,614] WARN Error while fetching metadata with correlation 
id 98 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,705] WARN Error while fetching metadata with correlation 
id 100 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,705] WARN Error while fetching metadata with correlation 
id 102 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,716] WARN Error while fetching metadata with correlation 
id 100 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,809] WARN Error while fetching metadata with correlation 
id 102 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,814] WARN Error while fetching metadata with correlation 
id 104 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,820] WARN Error while fetching metadata with correlation 
id 102 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,912] WARN Error while fetching metadata with correlation 
id 104 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,916] WARN Error while fetching metadata with correlation 
id 106 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:48,928] WARN Error while fetching metadata with correlation 
id 104 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,016] WARN Error while fetching metadata with correlation 
id 106 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,029] WARN Error while fetching metadata with correlation 
id 108 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,035] WARN Error while fetching metadata with correlation 
id 106 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,118] WARN Error while fetching metadata with correlation 
id 108 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,134] WARN Error while fetching metadata with correlation 
id 110 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,140] WARN Error while fetching metadata with correlation 
id 108 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,221] WARN Error while fetching metadata with correlation 
id 110 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,236] WARN Error while fetching metadata with correlation 
id 112 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,242] WARN Error while fetching metadata with correlation 
id 110 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,324] WARN Error while fetching metadata with correlation 
id 112 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,344] WARN Error while fetching metadata with correlation 
id 114 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,347] WARN Error while fetching metadata with correlation 
id 112 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,429] WARN Error while fetching metadata with correlation 
id 114 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,446] WARN Error while fetching metadata with correlation 
id 116 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:43:49,449] WARN Error while fetching metadata with correlation 
id 114 : 
{kstream-repartition-join-test-1-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-1-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:44:55,407] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:44:56,762] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:44:57,433] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:44:57,956] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:44:58,572] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:44:58,993] WARN caught end of stream exception 
(org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid 
0x159ad1904980012, likely client has closed socket
        at 
org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228)
        at 
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
        at java.lang.Thread.run(Thread.java:745)
[2017-01-17 15:44:59,998] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:45:00,590] WARN Session 0x0 for server null, unexpected error, 
closing socket connection and attempting reconnect 
(org.apache.zookeeper.ClientCnxn:1162)
java.net.ConnectException: Connection refused
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at 
sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744)
        at 
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361)
        at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
[2017-01-17 15:45:00,837] WARN caught end of stream exception 
(org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid 
0x159ad1904980016, likely client has closed socket
        at 
org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228)
        at 
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
        at java.lang.Thread.run(Thread.java:745)
[2017-01-17 15:45:01,097] WARN Error while fetching metadata with correlation 
id 2 : 
{kstream-repartition-join-test-2-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:45:01,100] WARN Error while fetching metadata with correlation 
id 2 : 
{kstream-repartition-join-test-2-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:45:01,109] WARN Error while fetching metadata with correlation 
id 2 : 
{kstream-repartition-join-test-2-KSTREAM-MAP-0000000058-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000028-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000069-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000068-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000095-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-FLATMAP-0000000048-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-KEY-SELECT-0000000038-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000096-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000082-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000014-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000013-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000081-repartition=UNKNOWN_TOPIC_OR_PARTITION,
 
kstream-repartition-join-test-2-KSTREAM-MAP-0000000003-repartition=UNKNOWN_TOPIC_OR_PARTITION}
 (org.apache.kafka.clients.NetworkClient:695)
[2017-01-17 15:46:10,278] ERROR ZKShutdownHandler is not registered, so 
ZooKeeper server won't take any action on ERROR or SHUTDOWN server state 
changes (org.apache.zookeeper.server.ZooKeeperServer:472)
{code}

> Unstable test 
> KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations
> -----------------------------------------------------------------------------------
>
>                 Key: KAFKA-3896
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3896
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: unit tests
>            Reporter: Ashish K Singh
>            Assignee: Damian Guy
>             Fix For: 0.10.1.0
>
>
> {{KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations}} 
> seems to be unstable. A failure can be found 
> [here|https://builds.apache.org/job/kafka-trunk-git-pr-jdk7/4363/]. Could not 
> reproduce the test failure locally though.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to