Skip to content

Instantly share code, notes, and snippets.

@clrxbl

clrxbl/gist:b12b70f76508718177f1186209ffbfc5

Created July 4, 2023 19:48
Download ZIP

Revisions

  1. clrxbl created this gist Jul 4, 2023.
    124 changes: 124 additions & 0 deletions gistfile1.txt
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,124 @@
    2023-07-04T19:45:25.025216Z TRACE ThreadId(25) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=394
    2023-07-04T19:45:25.025219Z TRACE ThreadId(25) getsockname: mirrord_layer::socket::ops: close time.busy=9.83µs time.idle=7.50µs sockfd=394
    2023-07-04T19:45:25.025227Z TRACE ThreadId(25) getsockname: mirrord_layer::socket::ops: new sockfd=394
    2023-07-04T19:45:25.025232Z TRACE ThreadId(25) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:52734,
    ) sockfd=394
    2023-07-04T19:45:25.025235Z TRACE ThreadId(25) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=394
    2023-07-04T19:45:25.025238Z TRACE ThreadId(25) getsockname: mirrord_layer::socket::ops: close time.busy=6.12µs time.idle=4.71µs sockfd=394
    2023-07-04T19:45:25.037526Z TRACE ThreadId(23) connect:connect_outgoing: mirrord_layer::socket::ops: return=Success(ConnectResult { result: -1, error: Some(Errno { code: 36, description: Some("Operation now in progress") }) }) sockfd=396 address_length=16 sockfd=396 remote_address=SockAddr { ss_len: 0, ss_family: 2, len: 16 } user_socket_info=UserSocket { id: SocketId(462), domain: 2, type_: 1, protocol: 0, state: Initialized, kind: Tcp(1) }
    2023-07-04T19:45:25.037543Z TRACE ThreadId(23) connect:connect_outgoing: mirrord_layer::socket::ops: close time.busy=46.1ms time.idle=6.21µs sockfd=396 address_length=16 sockfd=396 remote_address=SockAddr { ss_len: 0, ss_family: 2, len: 16 } user_socket_info=UserSocket { id: SocketId(462), domain: 2, type_: 1, protocol: 0, state: Initialized, kind: Tcp(1) }
    2023-07-04T19:45:25.037549Z TRACE ThreadId(23) connect: mirrord_layer::socket::ops: return=Success(ConnectResult { result: -1, error: Some(Errno { code: 36, description: Some("Operation now in progress") }) }) sockfd=396 address_length=16
    2023-07-04T19:45:25.037553Z TRACE ThreadId(23) connect: mirrord_layer::socket::ops: close time.busy=46.1ms time.idle=6.33µs sockfd=396 address_length=16
    2023-07-04T19:45:25.037767Z TRACE ThreadId(23) getsockname: mirrord_layer::socket::ops: new sockfd=393
    2023-07-04T19:45:25.037774Z TRACE ThreadId(23) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:50174,
    ) sockfd=393
    2023-07-04T19:45:25.037778Z TRACE ThreadId(23) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=393
    2023-07-04T19:45:25.037781Z TRACE ThreadId(23) getsockname: mirrord_layer::socket::ops: close time.busy=7.62µs time.idle=7.04µs sockfd=393
    2023-07-04T19:45:25.037790Z TRACE ThreadId(23) getsockname: mirrord_layer::socket::ops: new sockfd=393
    2023-07-04T19:45:25.037793Z TRACE ThreadId(23) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:50174,
    ) sockfd=393
    2023-07-04T19:45:25.037796Z TRACE ThreadId(23) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=393
    2023-07-04T19:45:25.037800Z TRACE ThreadId(23) getsockname: mirrord_layer::socket::ops: close time.busy=7.50µs time.idle=2.71µs sockfd=393
    2023-07-04T19:45:25.037875Z TRACE ThreadId(24) connect:connect_outgoing: mirrord_layer::socket::ops: return=Success(ConnectResult { result: -1, error: Some(Errno { code: 36, description: Some("Operation now in progress") }) }) sockfd=398 address_length=16 sockfd=398 remote_address=SockAddr { ss_len: 0, ss_family: 2, len: 16 } user_socket_info=UserSocket { id: SocketId(463), domain: 2, type_: 1, protocol: 0, state: Initialized, kind: Tcp(1) }
    2023-07-04T19:45:25.037889Z TRACE ThreadId(24) connect:connect_outgoing: mirrord_layer::socket::ops: close time.busy=46.3ms time.idle=4.71µs sockfd=398 address_length=16 sockfd=398 remote_address=SockAddr { ss_len: 0, ss_family: 2, len: 16 } user_socket_info=UserSocket { id: SocketId(463), domain: 2, type_: 1, protocol: 0, state: Initialized, kind: Tcp(1) }
    2023-07-04T19:45:25.037896Z TRACE ThreadId(24) connect: mirrord_layer::socket::ops: return=Success(ConnectResult { result: -1, error: Some(Errno { code: 36, description: Some("Operation now in progress") }) }) sockfd=398 address_length=16
    2023-07-04T19:45:25.037902Z TRACE ThreadId(24) connect: mirrord_layer::socket::ops: close time.busy=46.3ms time.idle=5.38µs sockfd=398 address_length=16
    2023-07-04T19:45:25.038109Z TRACE ThreadId(61) getsockname: mirrord_layer::socket::ops: new sockfd=396
    2023-07-04T19:45:25.038120Z TRACE ThreadId(61) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:52740,
    ) sockfd=396
    2023-07-04T19:45:25.038125Z TRACE ThreadId(61) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=396
    2023-07-04T19:45:25.038129Z TRACE ThreadId(61) getsockname: mirrord_layer::socket::ops: close time.busy=9.83µs time.idle=11.3µs sockfd=396
    2023-07-04T19:45:25.038140Z TRACE ThreadId(61) getsockname: mirrord_layer::socket::ops: new sockfd=396
    2023-07-04T19:45:25.038145Z TRACE ThreadId(61) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:52740,
    ) sockfd=396
    2023-07-04T19:45:25.038148Z TRACE ThreadId(61) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=396
    2023-07-04T19:45:25.038151Z TRACE ThreadId(61) getsockname: mirrord_layer::socket::ops: close time.busy=6.08µs time.idle=4.83µs sockfd=396
    2023-07-04 21:45:25.038 WARN 34729 --- [ntainer#0-1-C-1] org.apache.kafka.clients.NetworkClient : [Consumer clientId=consumer-network-svc-2, groupId=network-svc] Error connecting to node kafka-kafka-0.kafka-kafka-brokers.infra.svc:9092 (id: 0 rack: null)

    java.net.UnknownHostException: kafka-kafka-0.kafka-kafka-brokers.infra.svc
    at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:801) ~[na:na]
    at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1533) ~[na:na]
    at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1385) ~[na:na]
    at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306) ~[na:na]
    at org.apache.kafka.clients.DefaultHostResolver.resolve(DefaultHostResolver.java:27) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:110) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.currentAddress(ClusterConnectionStates.java:511) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.access$200(ClusterConnectionStates.java:468) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:173) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:988) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:301) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.trySend(ConsumerNetworkClient.java:498) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:255) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.consumer.KafkaConsumer.pollForFetches(KafkaConsumer.java:1297) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1238) ~[kafka-clients-3.1.2.jar!/:na]
    at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1211) ~[kafka-clients-3.1.2.jar!/:na]
    at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollConsumer(KafkaMessageListenerContainer.java:1531) ~[spring-kafka-2.8.11.jar!/:2.8.11]
    at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doPoll(KafkaMessageListenerContainer.java:1521) ~[spring-kafka-2.8.11.jar!/:2.8.11]
    at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1345) ~[spring-kafka-2.8.11.jar!/:2.8.11]
    at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1257) ~[spring-kafka-2.8.11.jar!/:2.8.11]
    at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[na:na]
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
    at java.base/java.lang.Thread.run(Thread.java:833) ~[na:na]

    2023-07-04T19:45:25.038481Z TRACE ThreadId(24) getsockname: mirrord_layer::socket::ops: new sockfd=398
    2023-07-04T19:45:25.038490Z TRACE ThreadId(24) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:50186,
    ) sockfd=398
    2023-07-04T19:45:25.038494Z TRACE ThreadId(24) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=398
    2023-07-04T19:45:25.038499Z TRACE ThreadId(24) getsockname: mirrord_layer::socket::ops: close time.busy=9.04µs time.idle=9.00µs sockfd=398
    2023-07-04T19:45:25.038509Z TRACE ThreadId(24) getsockname: mirrord_layer::socket::ops: new sockfd=398
    2023-07-04T19:45:25.038514Z TRACE ThreadId(24) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:50186,
    ) sockfd=398
    2023-07-04T19:45:25.038518Z TRACE ThreadId(24) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=398
    2023-07-04T19:45:25.038521Z TRACE ThreadId(24) getsockname: mirrord_layer::socket::ops: close time.busy=6.71µs time.idle=5.29µs sockfd=398
    2023-07-04T19:45:25.058416Z TRACE ThreadId(26) connect:connect_outgoing: mirrord_layer::socket::ops: return=Success(ConnectResult { result: -1, error: Some(Errno { code: 36, description: Some("Operation now in progress") }) }) sockfd=400 address_length=16 sockfd=400 remote_address=SockAddr { ss_len: 0, ss_family: 2, len: 16 } user_socket_info=UserSocket { id: SocketId(464), domain: 2, type_: 1, protocol: 0, state: Initialized, kind: Tcp(1) }
    2023-07-04T19:45:25.058438Z TRACE ThreadId(26) connect:connect_outgoing: mirrord_layer::socket::ops: close time.busy=53.0ms time.idle=6.00µs sockfd=400 address_length=16 sockfd=400 remote_address=SockAddr { ss_len: 0, ss_family: 2, len: 16 } user_socket_info=UserSocket { id: SocketId(464), domain: 2, type_: 1, protocol: 0, state: Initialized, kind: Tcp(1) }
    2023-07-04T19:45:25.058447Z TRACE ThreadId(26) connect: mirrord_layer::socket::ops: return=Success(ConnectResult { result: -1, error: Some(Errno { code: 36, description: Some("Operation now in progress") }) }) sockfd=400 address_length=16
    2023-07-04T19:45:25.058452Z TRACE ThreadId(26) connect: mirrord_layer::socket::ops: close time.busy=53.1ms time.idle=4.04µs sockfd=400 address_length=16
    2023-07-04T19:45:25.058681Z TRACE ThreadId(26) getsockname: mirrord_layer::socket::ops: new sockfd=392
    2023-07-04T19:45:25.058690Z TRACE ThreadId(26) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:52730,
    ) sockfd=392
    2023-07-04T19:45:25.058695Z TRACE ThreadId(26) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=392
    2023-07-04T19:45:25.058699Z TRACE ThreadId(26) getsockname: mirrord_layer::socket::ops: close time.busy=9.25µs time.idle=8.96µs sockfd=392
    2023-07-04T19:45:25.058709Z TRACE ThreadId(26) getsockname: mirrord_layer::socket::ops: new sockfd=392
    2023-07-04T19:45:25.058713Z TRACE ThreadId(26) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:52730,
    ) sockfd=392
    2023-07-04T19:45:25.058717Z TRACE ThreadId(26) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=392
    2023-07-04T19:45:25.058720Z TRACE ThreadId(26) getsockname: mirrord_layer::socket::ops: close time.busy=7.12µs time.idle=3.71µs sockfd=392
    2023-07-04T19:45:25.058737Z TRACE ThreadId(27) connect:connect_outgoing: mirrord_layer::socket::ops: return=Success(ConnectResult { result: -1, error: Some(Errno { code: 36, description: Some("Operation now in progress") }) }) sockfd=404 address_length=16 sockfd=404 remote_address=SockAddr { ss_len: 0, ss_family: 2, len: 16 } user_socket_info=UserSocket { id: SocketId(465), domain: 2, type_: 1, protocol: 0, state: Initialized, kind: Tcp(1) }
    2023-07-04T19:45:25.058749Z TRACE ThreadId(27) connect:connect_outgoing: mirrord_layer::socket::ops: close time.busy=33.7ms time.idle=5.79µs sockfd=404 address_length=16 sockfd=404 remote_address=SockAddr { ss_len: 0, ss_family: 2, len: 16 } user_socket_info=UserSocket { id: SocketId(465), domain: 2, type_: 1, protocol: 0, state: Initialized, kind: Tcp(1) }
    2023-07-04T19:45:25.058758Z TRACE ThreadId(27) connect: mirrord_layer::socket::ops: return=Success(ConnectResult { result: -1, error: Some(Errno { code: 36, description: Some("Operation now in progress") }) }) sockfd=404 address_length=16
    2023-07-04T19:45:25.058762Z TRACE ThreadId(27) connect: mirrord_layer::socket::ops: close time.busy=33.7ms time.idle=5.42µs sockfd=404 address_length=16
    2023-07-04T19:45:25.059090Z TRACE ThreadId(62) getsockname: mirrord_layer::socket::ops: new sockfd=400
    2023-07-04T19:45:25.059101Z TRACE ThreadId(62) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:50202,
    ) sockfd=400
    2023-07-04T19:45:25.059105Z TRACE ThreadId(62) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=400
    2023-07-04T19:45:25.059106Z TRACE ThreadId(63) getsockname: mirrord_layer::socket::ops: new sockfd=404
    2023-07-04T19:45:25.059114Z TRACE ThreadId(63) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:50208,
    ) sockfd=404
    2023-07-04T19:45:25.059117Z TRACE ThreadId(63) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=404
    2023-07-04T19:45:25.059109Z TRACE ThreadId(62) getsockname: mirrord_layer::socket::ops: close time.busy=8.54µs time.idle=11.3µs sockfd=400
    2023-07-04T19:45:25.059120Z TRACE ThreadId(63) getsockname: mirrord_layer::socket::ops: close time.busy=6.12µs time.idle=7.54µs sockfd=404
    2023-07-04T19:45:25.059127Z TRACE ThreadId(62) getsockname: mirrord_layer::socket::ops: new sockfd=400
    2023-07-04T19:45:25.059129Z TRACE ThreadId(63) getsockname: mirrord_layer::socket::ops: new sockfd=404
    2023-07-04T19:45:25.059130Z TRACE ThreadId(62) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:50202,
    ) sockfd=400
    2023-07-04T19:45:25.059138Z TRACE ThreadId(62) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=400
    2023-07-04T19:45:25.059142Z TRACE ThreadId(62) getsockname: mirrord_layer::socket::ops: close time.busy=11.6µs time.idle=3.29µs sockfd=400
    2023-07-04T19:45:25.059133Z TRACE ThreadId(63) getsockname: mirrord_layer::socket::ops: getsockname -> local_address Ip(
    172.16.0.194:50208,
    ) sockfd=404
    2023-07-04T19:45:25.059159Z TRACE ThreadId(63) getsockname: mirrord_layer::socket::ops: return=Success(0) sockfd=404
    2023-07-04T19:45:25.059167Z TRACE ThreadId(63) getsockname: mirrord_layer::socket::ops: close time.busy=34.0µs time.idle=4.08µs sockfd=404