[2020-10-02 16:46:32,638] WARN Query terminated due to exception:org.eclipse.jetty.io.EofException (io.confluent.ksql.rest.server.resources.streaming.QueryStreamWriter:95) [2020-10-02 16:46:32,640] INFO stream-client [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.KafkaStreams:285) [2020-10-02 16:46:32,647] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-1] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1116) [2020-10-02 16:46:32,650] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-1] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:221) [2020-10-02 16:46:32,652] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-2] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1116) [2020-10-02 16:46:32,656] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-2] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:221) [2020-10-02 16:46:32,659] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-3] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1116) [2020-10-02 16:46:32,661] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-3] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:221) [2020-10-02 16:46:32,663] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-4] Informed to shut down (org.apache.kafka.streams.processor.internals.StreamThread:1116) [2020-10-02 16:46:32,665] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-4] State transition from RUNNING to PENDING_SHUTDOWN (org.apache.kafka.streams.processor.internals.StreamThread:221) [2020-10-02 16:46:32,667] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-3] Shutting down (org.apache.kafka.streams.processor.internals.StreamThread:1130) [2020-10-02 16:46:32,732] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-2] Shutting down (org.apache.kafka.streams.processor.internals.StreamThread:1130) [2020-10-02 16:46:32,732] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-1] Shutting down (org.apache.kafka.streams.processor.internals.StreamThread:1130) [2020-10-02 16:46:32,759] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-4] Shutting down (org.apache.kafka.streams.processor.internals.StreamThread:1130) [2020-10-02 16:46:32,785] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-3] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread:221) [2020-10-02 16:46:32,786] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-3] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1150) [2020-10-02 16:46:32,843] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-2] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread:221) [2020-10-02 16:46:32,844] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-2] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1150) [2020-10-02 16:46:32,856] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-1] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread:221) [2020-10-02 16:46:32,859] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-1] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1150) [2020-10-02 16:46:32,869] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-4] State transition from PENDING_SHUTDOWN to DEAD (org.apache.kafka.streams.processor.internals.StreamThread:221) [2020-10-02 16:46:32,870] INFO stream-thread [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92-StreamThread-4] Shutdown complete (org.apache.kafka.streams.processor.internals.StreamThread:1150) [2020-10-02 16:46:32,874] INFO stream-client [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92] State transition from PENDING_SHUTDOWN to NOT_RUNNING (org.apache.kafka.streams.KafkaStreams:285) [2020-10-02 16:46:32,875] INFO stream-client [_confluent-ksql-default_transient_134713185169324032_1601653570667-cde01af6-9434-4902-b83a-663d68454f92] Streams client stopped completely (org.apache.kafka.streams.KafkaStreams:970) [2020-10-02 16:46:32,878] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 0_0 for task 0_0 as 1ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:32,884] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 0_1 for task 0_1 as 1ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:32,889] INFO stream-thread [qtp2032891036-47] Deleting state directory 0_2 for task 0_2 as user calling cleanup. (org.apache.kafka.streams.processor.internals.StateDirectory:313) [2020-10-02 16:46:32,895] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 0_3 for task 0_3 as 1ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:32,901] INFO stream-thread [qtp2032891036-47] Deleting state directory 0_4 for task 0_4 as user calling cleanup. (org.apache.kafka.streams.processor.internals.StateDirectory:313) [2020-10-02 16:46:32,907] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 0_5 for task 0_5 as 1ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:32,915] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 0_6 for task 0_6 as 1ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:32,922] INFO stream-thread [qtp2032891036-47] Deleting state directory 0_7 for task 0_7 as user calling cleanup. (org.apache.kafka.streams.processor.internals.StateDirectory:313) [2020-10-02 16:46:32,929] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 0_8 for task 0_8 as 1ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:32,937] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 0_9 for task 0_9 as 1ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:32,944] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_0 for task 1_0 as 257ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:32,970] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_1 for task 1_1 as 191ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:32,997] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_2 for task 1_2 as 237ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:33,022] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_3 for task 1_3 as 264ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:33,049] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_4 for task 1_4 as 338ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:33,075] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_5 for task 1_5 as 253ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:33,103] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_6 for task 1_6 as 292ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:33,138] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_7 for task 1_7 as 333ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:33,163] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_8 for task 1_8 as 416ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:33,191] INFO stream-thread [qtp2032891036-47] Deleting obsolete state directory 1_9 for task 1_9 as 341ms has elapsed (cleanup delay is 0ms). (org.apache.kafka.streams.processor.internals.StateDirectory:308) [2020-10-02 16:46:35,230] WARN Could not clean up the schema registry for query: _confluent-ksql-default_transient_134713185169324032_1601653570667 (io.confluent.ksql.schema.registry.SchemaRegistryUtil:59) java.net.ConnectException: Connection refused (Connection refused) at java.base/java.net.PlainSocketImpl.socketConnect(Native Method) at java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:399) at java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:242) at java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:224) at java.base/java.net.Socket.connect(Socket.java:609) at java.base/sun.net.NetworkClient.doConnect(NetworkClient.java:177) at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:474) at java.base/sun.net.www.http.HttpClient.openServer(HttpClient.java:569) at java.base/sun.net.www.http.HttpClient.(HttpClient.java:242) at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:341) at java.base/sun.net.www.http.HttpClient.New(HttpClient.java:362) at java.base/sun.net.www.protocol.http.HttpURLConnection.getNewHttpClient(HttpURLConnection.java:1253) at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect0(HttpURLConnection.java:1187) at java.base/sun.net.www.protocol.http.HttpURLConnection$6.run(HttpURLConnection.java:1071) at java.base/sun.net.www.protocol.http.HttpURLConnection$6.run(HttpURLConnection.java:1069) at java.base/java.security.AccessController.doPrivileged(Native Method) at java.base/java.security.AccessController.doPrivilegedWithCombiner(AccessController.java:795) at java.base/sun.net.www.protocol.http.HttpURLConnection.plainConnect(HttpURLConnection.java:1068) at java.base/sun.net.www.protocol.http.HttpURLConnection.connect(HttpURLConnection.java:1015) at java.base/sun.net.www.protocol.http.HttpURLConnection.getInputStream0(HttpURLConnection.java:1592) at java.base/sun.net.www.protocol.http.HttpURLConnection$9.run(HttpURLConnection.java:1512) at java.base/sun.net.www.protocol.http.HttpURLConnection$9.run(HttpURLConnection.java:1510) at java.base/java.security.AccessController.doPrivileged(Native Method) at java.base/java.security.AccessController.doPrivilegedWithCombiner(AccessController.java:795) at java.base/sun.net.www.protocol.http.HttpURLConnection.getInputStream(HttpURLConnection.java:1509) at java.base/java.net.HttpURLConnection.getResponseCode(HttpURLConnection.java:527) at io.confluent.kafka.schemaregistry.client.rest.RestService.sendHttpRequest(RestService.java:273) at io.confluent.kafka.schemaregistry.client.rest.RestService.httpRequest(RestService.java:352) at io.confluent.kafka.schemaregistry.client.rest.RestService.getAllSubjects(RestService.java:781) at io.confluent.kafka.schemaregistry.client.rest.RestService.getAllSubjects(RestService.java:776) at io.confluent.kafka.schemaregistry.client.CachedSchemaRegistryClient.getAllSubjects(CachedSchemaRegistryClient.java:471) at io.confluent.ksql.schema.registry.SchemaRegistryUtil.getSubjectNames(SchemaRegistryUtil.java:57) at io.confluent.ksql.schema.registry.SchemaRegistryUtil.getInternalSubjectNames(SchemaRegistryUtil.java:74) at io.confluent.ksql.schema.registry.SchemaRegistryUtil.cleanupInternalTopicSchemas(SchemaRegistryUtil.java:44) at io.confluent.ksql.engine.KsqlEngine.unregisterQuery(KsqlEngine.java:279) at io.confluent.ksql.engine.EngineContext.unregisterQuery(EngineContext.java:228) at io.confluent.ksql.util.QueryMetadata.close(QueryMetadata.java:194) at io.confluent.ksql.rest.server.resources.streaming.QueryStreamWriter.write(QueryStreamWriter.java:104) at org.glassfish.jersey.message.internal.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:55) at org.glassfish.jersey.message.internal.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:37) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor$TerminalWriterInterceptor.invokeWriteTo(WriterInterceptorExecutor.java:242) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor$TerminalWriterInterceptor.aroundWriteTo(WriterInterceptorExecutor.java:227) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor.proceed(WriterInterceptorExecutor.java:139) at org.glassfish.jersey.server.internal.JsonWithPaddingInterceptor.aroundWriteTo(JsonWithPaddingInterceptor.java:85) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor.proceed(WriterInterceptorExecutor.java:139) at org.glassfish.jersey.server.internal.MappableExceptionWrapperInterceptor.aroundWriteTo(MappableExceptionWrapperInterceptor.java:61) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor.proceed(WriterInterceptorExecutor.java:139) at org.glassfish.jersey.message.internal.MessageBodyFactory.writeTo(MessageBodyFactory.java:1116) at org.glassfish.jersey.server.ServerRuntime$Responder.writeResponse(ServerRuntime.java:638) at org.glassfish.jersey.server.ServerRuntime$Responder.processResponse(ServerRuntime.java:371) at org.glassfish.jersey.server.ServerRuntime$Responder.process(ServerRuntime.java:361) at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:256) at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248) at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244) at org.glassfish.jersey.internal.Errors.process(Errors.java:292) at org.glassfish.jersey.internal.Errors.process(Errors.java:274) at org.glassfish.jersey.internal.Errors.process(Errors.java:244) at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265) at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:232) at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:680) at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:394) at org.glassfish.jersey.servlet.ServletContainer.serviceImpl(ServletContainer.java:386) at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:561) at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:502) at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:439) at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604) at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:545) at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1607) at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1297) at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:485) at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1577) at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1212) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) at org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:173) at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:221) at org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:767) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) at org.eclipse.jetty.server.Server.handle(Server.java:500) at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:383) at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:547) at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:375) at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:270) at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103) at org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129) at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:388) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:806) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:938) at java.base/java.lang.Thread.run(Thread.java:834) [2020-10-02 16:46:38,020] WARN [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,020] WARN [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,037] WARN [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,037] WARN [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,120] WARN [AdminClient clientId=adminclient-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,120] WARN [AdminClient clientId=adminclient-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,126] WARN [Consumer clientId=consumer-ksql-connect-cluster-2, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,126] WARN [Consumer clientId=consumer-ksql-connect-cluster-2, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,134] WARN [Consumer clientId=consumer-ksql-connect-cluster-4, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,134] WARN [Consumer clientId=consumer-ksql-connect-cluster-4, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,133] WARN [Consumer clientId=consumer-1, groupId=null] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,133] WARN [Consumer clientId=consumer-1, groupId=null] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,133] WARN [Worker clientId=connect-1, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,133] WARN [Worker clientId=connect-1, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,131] WARN [Consumer clientId=consumer-ksql-connect-cluster-3, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,131] WARN [Consumer clientId=consumer-ksql-connect-cluster-3, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,166] WARN [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:38,166] WARN [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,127] WARN [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,127] WARN [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,148] WARN [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,148] WARN [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,224] WARN [AdminClient clientId=adminclient-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,224] WARN [AdminClient clientId=adminclient-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,237] WARN [Consumer clientId=consumer-ksql-connect-cluster-3, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,237] WARN [Consumer clientId=consumer-ksql-connect-cluster-3, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,242] WARN [Consumer clientId=consumer-1, groupId=null] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,242] WARN [Consumer clientId=consumer-1, groupId=null] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,240] WARN [Worker clientId=connect-1, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,240] WARN [Worker clientId=connect-1, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,282] WARN [Consumer clientId=consumer-ksql-connect-cluster-2, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,282] WARN [Consumer clientId=consumer-ksql-connect-cluster-2, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,295] WARN [Consumer clientId=consumer-ksql-connect-cluster-4, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,295] WARN [Consumer clientId=consumer-ksql-connect-cluster-4, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,321] WARN [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:40,321] WARN [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,231] WARN [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,231] WARN [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,259] WARN [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,259] WARN [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,444] WARN [Worker clientId=connect-1, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,444] WARN [Worker clientId=connect-1, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,463] WARN [AdminClient clientId=adminclient-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,463] WARN [AdminClient clientId=adminclient-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,489] WARN [Consumer clientId=consumer-ksql-connect-cluster-2, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,489] WARN [Consumer clientId=consumer-ksql-connect-cluster-2, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,496] WARN [Consumer clientId=consumer-ksql-connect-cluster-3, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,496] WARN [Consumer clientId=consumer-ksql-connect-cluster-3, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,503] WARN [Consumer clientId=consumer-ksql-connect-cluster-4, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,503] WARN [Consumer clientId=consumer-ksql-connect-cluster-4, groupId=ksql-connect-cluster] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,501] WARN [Consumer clientId=consumer-1, groupId=null] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,501] WARN [Consumer clientId=consumer-1, groupId=null] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,526] WARN [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:42,526] WARN [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) ^C[2020-10-02 16:46:43,757] INFO Stopped http_8083@4b93dd6a{HTTP/1.1,[http/1.1]}{0.0.0.0:8083} (org.eclipse.jetty.server.AbstractConnector:380) [2020-10-02 16:46:43,758] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:158) [2020-10-02 16:46:44,756] INFO Stopped NetworkTrafficServerConnector@4e928fbf{HTTP/1.1,[http/1.1]}{0.0.0.0:8088} (org.eclipse.jetty.server.AbstractConnector:380) [2020-10-02 16:46:44,758] INFO node0 Stopped scavenging (org.eclipse.jetty.server.session:158) [2020-10-02 16:46:44,768] INFO Stopped o.e.j.s.ServletContextHandler@515940af{/ws,null,UNAVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:1016) [2020-10-02 16:46:44,810] INFO Stopped o.e.j.s.ServletContextHandler@5f8df69{/,null,UNAVAILABLE} (org.eclipse.jetty.server.handler.ContextHandler:1016) [2020-10-02 16:46:44,819] WARN [AdminClient clientId=adminclient-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:44,819] WARN [AdminClient clientId=adminclient-1] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:44,963] WARN [Consumer clientId=consumer-1, groupId=null] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:44,963] WARN [Consumer clientId=consumer-1, groupId=null] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:763) [2020-10-02 16:46:45,314] ERROR Could not delete topic '_confluent-ksql-default_transient_134713185169324032_1601653570667-Aggregate-GroupBy-repartition' (io.confluent.ksql.services.KafkaTopicClient:279) java.lang.InterruptedException at java.base/java.lang.Object.wait(Native Method) at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:110) at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:272) at io.confluent.ksql.services.KafkaTopicClientImpl.deleteTopics(KafkaTopicClientImpl.java:267) at io.confluent.ksql.services.KafkaTopicClientImpl.deleteInternalTopics(KafkaTopicClientImpl.java:303) at io.confluent.ksql.engine.KsqlEngine.unregisterQuery(KsqlEngine.java:280) at io.confluent.ksql.engine.EngineContext.unregisterQuery(EngineContext.java:228) at io.confluent.ksql.util.QueryMetadata.close(QueryMetadata.java:194) at io.confluent.ksql.rest.server.resources.streaming.QueryStreamWriter.write(QueryStreamWriter.java:104) at org.glassfish.jersey.message.internal.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:55) at org.glassfish.jersey.message.internal.StreamingOutputProvider.writeTo(StreamingOutputProvider.java:37) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor$TerminalWriterInterceptor.invokeWriteTo(WriterInterceptorExecutor.java:242) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor$TerminalWriterInterceptor.aroundWriteTo(WriterInterceptorExecutor.java:227) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor.proceed(WriterInterceptorExecutor.java:139) at org.glassfish.jersey.server.internal.JsonWithPaddingInterceptor.aroundWriteTo(JsonWithPaddingInterceptor.java:85) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor.proceed(WriterInterceptorExecutor.java:139) at org.glassfish.jersey.server.internal.MappableExceptionWrapperInterceptor.aroundWriteTo(MappableExceptionWrapperInterceptor.java:61) at org.glassfish.jersey.message.internal.WriterInterceptorExecutor.proceed(WriterInterceptorExecutor.java:139) at org.glassfish.jersey.message.internal.MessageBodyFactory.writeTo(MessageBodyFactory.java:1116) at org.glassfish.jersey.server.ServerRuntime$Responder.writeResponse(ServerRuntime.java:638) at org.glassfish.jersey.server.ServerRuntime$Responder.processResponse(ServerRuntime.java:371) at org.glassfish.jersey.server.ServerRuntime$Responder.process(ServerRuntime.java:361) at org.glassfish.jersey.server.ServerRuntime$1.run(ServerRuntime.java:256) at org.glassfish.jersey.internal.Errors$1.call(Errors.java:248) at org.glassfish.jersey.internal.Errors$1.call(Errors.java:244) at org.glassfish.jersey.internal.Errors.process(Errors.java:292) at org.glassfish.jersey.internal.Errors.process(Errors.java:274) at org.glassfish.jersey.internal.Errors.process(Errors.java:244) at org.glassfish.jersey.process.internal.RequestScope.runInScope(RequestScope.java:265) at org.glassfish.jersey.server.ServerRuntime.process(ServerRuntime.java:232) at org.glassfish.jersey.server.ApplicationHandler.handle(ApplicationHandler.java:680) at org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:394) at org.glassfish.jersey.servlet.ServletContainer.serviceImpl(ServletContainer.java:386) at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:561) at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:502) at org.glassfish.jersey.servlet.ServletContainer.doFilter(ServletContainer.java:439) at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1604) at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:545) at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:1607) at org.eclipse.jetty.server.handler.ScopedHandler.nextHandle(ScopedHandler.java:233) at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1297) at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:188) at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:485) at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:1577) at org.eclipse.jetty.server.handler.ScopedHandler.nextScope(ScopedHandler.java:186) at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1212) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141) at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:146) at org.eclipse.jetty.server.handler.StatisticsHandler.handle(StatisticsHandler.java:173) at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:221) at org.eclipse.jetty.server.handler.gzip.GzipHandler.handle(GzipHandler.java:767) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:127) at org.eclipse.jetty.server.Server.handle(Server.java:500) at org.eclipse.jetty.server.HttpChannel.lambda$handle$1(HttpChannel.java:383) at org.eclipse.jetty.server.HttpChannel.dispatch(HttpChannel.java:547) at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:375) at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:270) at org.eclipse.jetty.io.AbstractConnection$ReadCallback.succeeded(AbstractConnection.java:311) at org.eclipse.jetty.io.FillInterest.fillable(FillInterest.java:103) at org.eclipse.jetty.io.ChannelEndPoint$2.run(ChannelEndPoint.java:117) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.runTask(EatWhatYouKill.java:336) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.doProduce(EatWhatYouKill.java:313) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.tryProduce(EatWhatYouKill.java:171) at org.eclipse.jetty.util.thread.strategy.EatWhatYouKill.run(EatWhatYouKill.java:129) at org.eclipse.jetty.util.thread.ReservedThreadExecutor$ReservedThread.run(ReservedThreadExecutor.java:388) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:806) at org.eclipse.jetty.util.thread.QueuedThreadPool$Runner.run(QueuedThreadPool.java:938) at java.base/java.lang.Thread.run(Thread.java:834) [2020-10-02 16:46:45,813] WARN QueuedThreadPool[qtp2032891036]@792b749c{STOPPING,8<=0<=200,i=7,r=-1,q=0}[NO_TRY] Couldn't stop Thread[qtp2032891036-47,5,main] (org.eclipse.jetty.util.thread.QueuedThreadPool:243)