Strimzi
Kafka pods not coming up due to an error in cluster operator #8410
Replies: 2 comments 6 replies
-
|
Would it be possible to share the log in some readable format? If you have it only as JSON, at least formatting it as such might help. |
Beta Was this translation helpful? Give feedback.
-
|
{ I hope its better now. |
Beta Was this translation helpful? Give feedback.
-
{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:34.672+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/41(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"292"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:34.686+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/41(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"328"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:34.688+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/42(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"292"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:34.688+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/42(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"328"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:35.640+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/43(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"292"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:35.691+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/43(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"328"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:35.692+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/44(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"292"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:35.694+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/44(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"328"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:36.472+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/45(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"292"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:36.484+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/issues/45(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"328"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:36.485+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/pull/46(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"292"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:36.485+00:00",
"severity":"info",
"service_id":"eric-data-messagebus-kf",
"message":"Reconciliation https://github.com/strimzi/strimzi-kafka-operator/pull/46(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StrimziPodSetController.java",
"line":"328"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:36.755+00:00",
"severity":"error",
"service_id":"eric-data-messagebus-kf",
"message":"Unable to resolve address: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc: Name or service not known|\tat java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)|\tat java.base/java.net.InetAddress$PlatformNameService.lookupAllHostAddr(InetAddress.java:929)|\tat java.base/java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1529)|\tat java.base/java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:848)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StaticHostProvider.java",
"line":"148"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:36.781+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"future isn't success. java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:394)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxnSocketNetty.java",
"line":"150"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:37.046+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:37.048+00:00",
"severity":"error",
"service_id":"eric-data-messagebus-kf",
"message":"Unable to resolve address: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc: Name or service not known|\tat java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)|\tat java.base/java.net.InetAddress$PlatformNameService.lookupAllHostAddr(InetAddress.java:929)|\tat java.base/java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1529)|\tat java.base/java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:848)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StaticHostProvider.java",
"line":"148"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:37.975+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"future isn't success. java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxnSocketNetty.java",
"line":"150"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:37.976+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:38.977+00:00",
"severity":"error",
"service_id":"eric-data-messagebus-kf",
"message":"Unable to resolve address: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StaticHostProvider.java",
"line":"148"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:39.594+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"future isn't success. java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxnSocketNetty.java",
"line":"150"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:39.595+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:40.385+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:40.385+00:00",
"severity":"error",
"service_id":"eric-data-messagebus-kf",
"message":"Unable to resolve address: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StaticHostProvider.java",
"line":"148"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:40.767+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"future isn't success. java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxnSocketNetty.java",
"line":"150"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:40.767+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:41.768+00:00",
"severity":"error",
"service_id":"eric-data-messagebus-kf",
"message":"Unable to resolve address: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StaticHostProvider.java",
"line":"148"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:42.656+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"future isn't success. java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxnSocketNetty.java",
"line":"150"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:42.657+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:43.286+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:43.287+00:00",
"severity":"error",
"service_id":"eric-data-messagebus-kf",
"message":"Unable to resolve address: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StaticHostProvider.java",
"line":"148"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:43.390+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"future isn't success. java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxnSocketNetty.java",
"line":"150"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:43.391+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:44.391+00:00",
"severity":"error",
"service_id":"eric-data-messagebus-kf",
"message":"Unable to resolve address: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StaticHostProvider.java",
"line":"148"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:44.781+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"future isn't success. java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxnSocketNetty.java",
"line":"150"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:44.782+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:45.699+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:45.699+00:00",
"severity":"error",
"service_id":"eric-data-messagebus-kf",
"message":"Unable to resolve address: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"StaticHostProvider.java",
"line":"148"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:46.494+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"future isn't success. java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxnSocketNetty.java",
"line":"150"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:46.495+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:48.206+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc/10.2.126.132:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:48.400+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:49.597+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:51.423+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc/10.2.126.132:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:51.743+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:52.051+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:53.931+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc/10.2.126.132:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:54.187+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T06:12:54.880+00:00",
"severity":"warning",
"service_id":"eric-data-messagebus-kf",
"message":"Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)",
"metadata":{
"container_name":"cluster-operator",
"pod_name":"eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"
},
"extra_data":{
"file":"ClientCnxn.java",
"line":"1300"
}
} |
Beta Was this translation helpful? Give feedback.
-
|
I can see similar error in zookeeper logs as well. But this works sometimes, I do not always get these errors. {
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.286+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, tries=3, remaining init limit=9699, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"434",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.297+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:FOLLOWING; n.sid:3, n.state:LOOKING, n.leader:3, n.round:0x7c17, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.386+00:00",
"severity":"error",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, retries exceeded. tries=4, remaining init limit=9598, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"426",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.386+00:00",
"severity":"error",
"service_id":"test-data-messagebus-kf",
"message":"Failed connect to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"378",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.386+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Exception when following the leader java.io.IOException: Failed connect to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888|\tat org.apache.zookeeper.server.quorum.Learner.connectToLeader(Learner.java:335)|\tat org.apache.zookeeper.server.quorum.Follower.followLeader(Follower.java:87)|\tat org.apache.zookeeper.server.quorum.QuorumPeer.run(QuorumPeer.java:1467)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Follower.java",
"line":"129",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.386+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"shutdown Follower",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Follower.java",
"line":"292",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.386+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Peer state changed: looking",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"864",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.386+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"PeerState set to LOOKING",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"1513",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.386+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"LOOKING",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"1383",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.387+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"New election. My id = 1, proposed zxid=0x10000004d",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"944",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.387+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:1, n.state:LOOKING, n.leader:1, n.round:0x7c16, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.387+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:3, n.state:LOOKING, n.leader:3, n.round:0x7c17, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.387+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:2, n.state:FOLLOWING, n.leader:3, n.round:0x7c16, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.387+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:1, n.state:LOOKING, n.leader:3, n.round:0x7c17, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.388+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:2, n.state:FOLLOWING, n.leader:3, n.round:0x7c16, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Peer state changed: following",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"858",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"FOLLOWING",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"1465",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"minSessionTimeout set to 4000",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"1273",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"maxSessionTimeout set to 40000",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"1282",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Response cache size is initialized with value 400.",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ResponseCache.java",
"line":"45",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Response cache size is initialized with value 400.",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ResponseCache.java",
"line":"45",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.slotCapacity = 60",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"109",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.slotDuration = 15",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"110",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.maxDepth = 6",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"111",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.initialDelay = 5",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"112",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.delay = 5",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"113",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.enabled = false",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"114",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"The max bytes for all large requests are set to 104857600",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"1498",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"The large request threshold is set to -1",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"1512",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Created server with tickTime 2000 minSessionTimeout 4000 maxSessionTimeout 40000 clientPortListenBacklog -1 datadir /var/lib/zookeeper/data/version-2 snapdir /var/lib/zookeeper/data/version-2",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"339",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"FOLLOWING - LEADER ELECTION TOOK - 202 MS",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Follower.java",
"line":"75",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.588+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Peer state changed: following - discovery",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"864",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.589+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:FOLLOWING; n.sid:3, n.state:LOOKING, n.leader:3, n.round:0x7c18, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.589+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, tries=0, remaining init limit=10000, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"434",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.690+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, tries=1, remaining init limit=9900, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"434",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.701+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:FOLLOWING; n.sid:2, n.state:LOOKING, n.leader:2, n.round:0x7c17, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.701+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:FOLLOWING; n.sid:2, n.state:LOOKING, n.leader:3, n.round:0x7c18, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.790+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, tries=2, remaining init limit=9799, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"434",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.891+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, tries=3, remaining init limit=9699, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"434",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.903+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:FOLLOWING; n.sid:3, n.state:LOOKING, n.leader:3, n.round:0x7c19, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.992+00:00",
"severity":"error",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, retries exceeded. tries=4, remaining init limit=9598, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"426",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.992+00:00",
"severity":"error",
"service_id":"test-data-messagebus-kf",
"message":"Failed connect to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"378",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.992+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Exception when following the leader java.io.IOException: Failed connect to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888|\tat org.apache.zookeeper.server.quorum.Learner.connectToLeader(Learner.java:335)|\tat org.apache.zookeeper.server.quorum.Follower.followLeader(Follower.java:87)|\tat org.apache.zookeeper.server.quorum.QuorumPeer.run(QuorumPeer.java:1467)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Follower.java",
"line":"129",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.992+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"shutdown Follower",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Follower.java",
"line":"292",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.992+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Peer state changed: looking",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"864",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.992+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"PeerState set to LOOKING",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"1513",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.992+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"LOOKING",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"1383",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.992+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"New election. My id = 1, proposed zxid=0x10000004d",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"944",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.992+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:1, n.state:LOOKING, n.leader:1, n.round:0x7c18, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.993+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:3, n.state:LOOKING, n.leader:3, n.round:0x7c19, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.993+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:2, n.state:FOLLOWING, n.leader:3, n.round:0x7c18, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.993+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:1, n.state:LOOKING, n.leader:3, n.round:0x7c19, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:26.993+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:LOOKING; n.sid:2, n.state:FOLLOWING, n.leader:3, n.round:0x7c18, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Peer state changed: following",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"858",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"FOLLOWING",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"1465",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"minSessionTimeout set to 4000",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"1273",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"maxSessionTimeout set to 40000",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"1282",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Response cache size is initialized with value 400.",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ResponseCache.java",
"line":"45",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Response cache size is initialized with value 400.",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ResponseCache.java",
"line":"45",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.slotCapacity = 60",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"109",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.slotDuration = 15",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"110",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.maxDepth = 6",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"111",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.initialDelay = 5",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"112",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.delay = 5",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"113",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"zookeeper.pathStats.enabled = false",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"RequestPathMetricsCollector.java",
"line":"114",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"The max bytes for all large requests are set to 104857600",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"1498",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"The large request threshold is set to -1",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"1512",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Created server with tickTime 2000 minSessionTimeout 4000 maxSessionTimeout 40000 clientPortListenBacklog -1 datadir /var/lib/zookeeper/data/version-2 snapdir /var/lib/zookeeper/data/version-2",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"ZooKeeperServer.java",
"line":"339",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"FOLLOWING - LEADER ELECTION TOOK - 202 MS",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Follower.java",
"line":"75",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.194+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Peer state changed: following - discovery",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"QuorumPeer.java",
"line":"864",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.195+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:FOLLOWING; n.sid:3, n.state:LOOKING, n.leader:3, n.round:0x7c1a, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.195+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, tries=0, remaining init limit=10000, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"434",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.295+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, tries=1, remaining init limit=9900, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"434",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.306+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:FOLLOWING; n.sid:2, n.state:LOOKING, n.leader:2, n.round:0x7c19, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.306+00:00",
"severity":"info",
"service_id":"test-data-messagebus-kf",
"message":"Notification: my state:FOLLOWING; n.sid:2, n.state:LOOKING, n.leader:3, n.round:0x7c1a, n.peerEpoch:0x1, n.zxid:0x10000004d, message format version:0x2, n.config version:0x0",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"FastLeaderElection.java",
"line":"389",
"mbkf_cluster_name":"kafka100"
}
}{
"version":"1.2.0",
"timestamp":"2023-04-19T09:03:27.396+00:00",
"severity":"warning",
"service_id":"test-data-messagebus-kf",
"message":"Unexpected exception, tries=2, remaining init limit=9799, connecting to kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2888 java.net.ConnectException: Connection refused (Connection refused)|\tat java.base/java.net.PlainSocketImpl.socketConnect(Native Method)|\tat java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:412)|\tat java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:255)|\tat java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:237)|\tat java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)|\tat java.base/java.net.Socket.connect(Socket.java:609)|\tat java.base/sun.security.ssl.SSLSocketImpl.connect(SSLSocketImpl.java:305)|\tat org.apache.zookeeper.server.quorum.Learner.sockConnect(Learner.java:292)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.connectToLeader(Learner.java:408)|\tat org.apache.zookeeper.server.quorum.Learner$LeaderConnector.run(Learner.java:366)|\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)|\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)|\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)|\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)|\tat java.base/java.lang.Thread.run(Thread.java:829)",
"metadata":{
"container_name":"zookeeper",
"pod_name":"kafka100-zookeeper-0"
},
"extra_data":{
"file":"Learner.java",
"line":"434",
"mbkf_cluster_name":"kafka100"
}
} |
Beta Was this translation helpful? Give feedback.
-
|
To be honest, as far as I can see, it seems that the ZooKeeper nodes did not form the cluster and they seem to have issues connecting with each other. I guess you can try to check your networking. |
Beta Was this translation helpful? Give feedback.
-
|
I will try to check my networking, but I have been using Apache Zookeeper on this machine and never faced any such issue, but now I am facing this issue very frequently while using Strimzi. |
Beta Was this translation helpful? Give feedback.
-
|
Everything else seems to be working file except this, so doesn't seem to be a networking issue. |
Beta Was this translation helpful? Give feedback.
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
Hi,
I am trying to install a Strimzi cluster but intermittently Kafka pods does not come up.
Below error is visible in the cluster operator logs (Connection to zookeeper is not available):
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:34.672+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #41(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "292"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:34.686+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #41(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "328"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:34.688+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #42(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "292"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:34.688+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #42(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "328"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:35.640+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #43(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "292"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:35.691+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #43(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "328"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:35.692+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #44(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "292"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:35.694+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #44(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "328"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:36.472+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #45(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "292"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:36.484+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #45(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "328"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:36.485+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #46(watch) StrimziPodSet(kafka/kafka100-zookeeper): StrimziPodSet will be reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "292"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:36.485+00:00", "severity": "info", "service_id": "eric-data-messagebus-kf", "message": "Reconciliation #46(watch) StrimziPodSet(kafka/kafka100-zookeeper): reconciled", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StrimziPodSetController.java", "line": "328"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:36.755+00:00", "severity": "error", "service_id": "eric-data-messagebus-kf", "message": "Unable to resolve address: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc: Name or service not known|\tat java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)|\tat java.base/java.net.InetAddress$PlatformNameService.lookupAllHostAddr(InetAddress.java:929)|\tat java.base/java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1529)|\tat java.base/java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:848)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StaticHostProvider.java", "line": "148"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:36.781+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "future isn't success. java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:394)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxnSocketNetty.java", "line": "150"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:37.046+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:37.048+00:00", "severity": "error", "service_id": "eric-data-messagebus-kf", "message": "Unable to resolve address: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc: Name or service not known|\tat java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)|\tat java.base/java.net.InetAddress$PlatformNameService.lookupAllHostAddr(InetAddress.java:929)|\tat java.base/java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1529)|\tat java.base/java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:848)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StaticHostProvider.java", "line": "148"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:37.975+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "future isn't success. java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxnSocketNetty.java", "line": "150"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:37.976+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:38.977+00:00", "severity": "error", "service_id": "eric-data-messagebus-kf", "message": "Unable to resolve address: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StaticHostProvider.java", "line": "148"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:39.594+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "future isn't success. java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxnSocketNetty.java", "line": "150"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:39.595+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:40.385+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:40.385+00:00", "severity": "error", "service_id": "eric-data-messagebus-kf", "message": "Unable to resolve address: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StaticHostProvider.java", "line": "148"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:40.767+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "future isn't success. java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxnSocketNetty.java", "line": "150"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:40.767+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:41.768+00:00", "severity": "error", "service_id": "eric-data-messagebus-kf", "message": "Unable to resolve address: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StaticHostProvider.java", "line": "148"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:42.656+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "future isn't success. java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxnSocketNetty.java", "line": "150"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:42.657+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:43.286+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:43.287+00:00", "severity": "error", "service_id": "eric-data-messagebus-kf", "message": "Unable to resolve address: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StaticHostProvider.java", "line": "148"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:43.390+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "future isn't success. java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxnSocketNetty.java", "line": "150"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:43.391+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:44.391+00:00", "severity": "error", "service_id": "eric-data-messagebus-kf", "message": "Unable to resolve address: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StaticHostProvider.java", "line": "148"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:44.781+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "future isn't success. java.net.UnknownHostException: kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxnSocketNetty.java", "line": "150"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:44.782+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:45.699+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:45.699+00:00", "severity": "error", "service_id": "eric-data-messagebus-kf", "message": "Unable to resolve address: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181 java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat org.apache.zookeeper.client.StaticHostProvider$1.getAllByName(StaticHostProvider.java:88)|\tat org.apache.zookeeper.client.StaticHostProvider.resolve(StaticHostProvider.java:141)|\tat org.apache.zookeeper.client.StaticHostProvider.next(StaticHostProvider.java:368)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1207)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "StaticHostProvider.java", "line": "148"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:46.494+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "future isn't success. java.net.UnknownHostException: kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc|\tat java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:797)|\tat java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1519)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1378)|\tat java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)|\tat java.base/java.net.InetAddress.getByName(InetAddress.java:1256)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:156)|\tat io.netty.util.internal.SocketUtils$8.run(SocketUtils.java:153)|\tat java.base/java.security.AccessController.doPrivileged(Native Method)|\tat io.netty.util.internal.SocketUtils.addressByName(SocketUtils.java:153)|\tat io.netty.resolver.DefaultNameResolver.doResolve(DefaultNameResolver.java:41)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:61)|\tat io.netty.resolver.SimpleNameResolver.resolve(SimpleNameResolver.java:53)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:55)|\tat io.netty.resolver.InetSocketAddressResolver.doResolve(InetSocketAddressResolver.java:31)|\tat io.netty.resolver.AbstractAddressResolver.resolve(AbstractAddressResolver.java:106)|\tat io.netty.bootstrap.Bootstrap.doResolveAndConnect0(Bootstrap.java:206)|\tat io.netty.bootstrap.Bootstrap.access$000(Bootstrap.java:46)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:180)|\tat io.netty.bootstrap.Bootstrap$1.operationComplete(Bootstrap.java:166)|\tat io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:578)|\tat io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:552)|\tat io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:491)|\tat io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:616)|\tat io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:605)|\tat io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:104)|\tat io.netty.channel.DefaultChannelPromise.trySuccess(DefaultChannelPromise.java:84)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.safeSetSuccess(AbstractChannel.java:990)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:516)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe.access$200(AbstractChannel.java:429)|\tat io.netty.channel.AbstractChannel$AbstractUnsafe$1.run(AbstractChannel.java:486)|\tat io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)|\tat io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)|\tat io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)|\tat io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:391)|\tat io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:995)|\tat io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)|\tat io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)|\tat java.base/java.lang.Thread.run(Thread.java:829)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxnSocketNetty.java", "line": "150"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:46.495+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:48.206+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc/10.2.126.132:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:48.400+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:49.597+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:51.423+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc/10.2.126.132:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:51.743+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:52.051+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:53.931+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-1.kafka100-zookeeper-nodes.kafka.svc/10.2.126.132:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:54.187+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-0.kafka100-zookeeper-nodes.kafka.svc/10.2.126.177:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
{"version": "1.2.0", "timestamp": "2023-04-19T06:12:54.880+00:00", "severity": "warning", "service_id": "eric-data-messagebus-kf", "message": "Session 0x0 for sever kafka100-zookeeper-2.kafka100-zookeeper-nodes.kafka.svc/10.2.126.166:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. EndOfStreamException: channel for sessionid 0x0 is lost|\tat org.apache.zookeeper.ClientCnxnSocketNetty.doTransport(ClientCnxnSocketNetty.java:285)|\tat org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290)", "metadata": {"container_name": "cluster-operator", "pod_name": "eric-data-message-bus-kf-operator-fb44bf87b-fmwgx"}, "extra_data": {"file": "ClientCnxn.java", "line": "1300"}}
Beta Was this translation helpful? Give feedback.
All reactions