Untitled

avatar
unknown
plain_text
a year ago
9.6 kB
11
Indexable
2024-07-18T14:23:02.990Z DEBUG 7 --- [d5c37afaa-0-C-1] o.a.k.c.s.a.SaslClientAuthenticator      : [Consumer clientId=consumer-case-management-group-3, groupId=case-management-group] Set SASL client state to SEND_APIVERSIONS_REQUEST
2024-07-18T14:23:02.990Z DEBUG 7 --- [d5c37afaa-0-C-1] o.a.k.c.s.a.SaslClientAuthenticator      : [Consumer clientId=consumer-case-management-group-3, groupId=case-management-group] Creating SaslClient: client=null;service=kafka;serviceHostname=mpt-oci-kafka.computesubnet.moniepointngdev.oraclevcn.com;mechs=[PLAIN]
2024-07-18T14:23:02.991Z DEBUG 7 --- [d5c37afaa-0-C-1] o.apache.kafka.common.network.Selector   : [Consumer clientId=consumer-case-management-group-3, groupId=case-management-group] Created socket with SO_RCVBUF = 65536, SO_SNDBUF = 131072, SO_TIMEOUT = 0 to node -1
2024-07-18T14:23:02.993Z DEBUG 7 --- [d5c37afaa-0-C-1] o.apache.kafka.common.network.Selector   : [Consumer clientId=consumer-case-management-group-3, groupId=case-management-group] Connection with mpt-oci-kafka.computesubnet.moniepointngdev.oraclevcn.com/10.0.30.108 (channelId=-1) disconnected

java.io.EOFException: EOF during handshake, handshake status is NEED_UNWRAP
	at org.apache.kafka.common.network.SslTransportLayer.handshakeUnwrap(SslTransportLayer.java:534) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.SslTransportLayer.doHandshake(SslTransportLayer.java:373) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.SslTransportLayer.handshake(SslTransportLayer.java:293) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.KafkaChannel.prepare(KafkaChannel.java:178) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:543) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.Selector.poll(Selector.java:481) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:281) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:252) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:243) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:165) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:302) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:263) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.coordinatorUnknownAndUnreadySync(ConsumerCoordinator.java:446) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:478) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer.updateAssignmentMetadataIfNeeded(LegacyKafkaConsumer.java:651) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer.poll(LegacyKafkaConsumer.java:610) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer.poll(LegacyKafkaConsumer.java:590) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:874) ~[kafka-clients-3.7.0.jar!/:na]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollConsumer(KafkaMessageListenerContainer.java:1625) ~[spring-kafka-3.2.1.jar!/:3.2.1]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doPoll(KafkaMessageListenerContainer.java:1600) ~[spring-kafka-3.2.1.jar!/:3.2.1]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1405) ~[spring-kafka-3.2.1.jar!/:3.2.1]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1296) ~[spring-kafka-3.2.1.jar!/:3.2.1]
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(Unknown Source) ~[na:na]
	at util.TokenAwareRunnable.run(TokenAwareRunnable.java:28) ~[na:na]
	at java.base/java.lang.Thread.run(Unknown Source) ~[na:na]

2024-07-18T14:23:02.993Z DEBUG 7 --- [d5c37afaa-0-C-1] o.a.k.common.network.SslTransportLayer   : [SslTransportLayer channelId=-1 key=channel=java.nio.channels.SocketChannel[connection-pending remote=/10.0.30.108:9092], selector=sun.nio.ch.EPollSelectorImpl@7e89b842, interestOps=8, readyOps=0] Failed to send SSL Close message

java.io.IOException: Unexpected status returned by SSLEngine.wrap, expected CLOSED, received OK. Will not send close message to peer.
	at org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:194) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:1047) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:155) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.Selector.doClose(Selector.java:956) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.Selector.close(Selector.java:940) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:625) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.common.network.Selector.poll(Selector.java:481) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:585) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:281) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:252) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:243) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:165) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:302) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:263) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.coordinatorUnknownAndUnreadySync(ConsumerCoordinator.java:446) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:478) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer.updateAssignmentMetadataIfNeeded(LegacyKafkaConsumer.java:651) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer.poll(LegacyKafkaConsumer.java:610) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.internals.LegacyKafkaConsumer.poll(LegacyKafkaConsumer.java:590) ~[kafka-clients-3.7.0.jar!/:na]
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:874) ~[kafka-clients-3.7.0.jar!/:na]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollConsumer(KafkaMessageListenerContainer.java:1625) ~[spring-kafka-3.2.1.jar!/:3.2.1]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doPoll(KafkaMessageListenerContainer.java:1600) ~[spring-kafka-3.2.1.jar!/:3.2.1]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1405) ~[spring-kafka-3.2.1.jar!/:3.2.1]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1296) ~[spring-kafka-3.2.1.jar!/:3.2.1]
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(Unknown Source) ~[na:na]
	at util.TokenAwareRunnable.run(TokenAwareRunnable.java:28) ~[na:na]
	at java.base/java.lang.Thread.run(Unknown Source) ~[na:na]

2024-07-18T14:23:02.993Z  INFO 7 --- [d5c37afaa-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-case-management-group-3, groupId=case-management-group] Node -1 disconnected.
2024-07-18T14:23:02.993Z  WARN 7 --- [d5c37afaa-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-case-management-group-3, groupId=case-management-group] Connection to node -1 (mpt-oci-kafka.computesubnet.moniepointngdev.oraclevcn.com/10.0.30.108:9092) terminated during authentication. This may happen due to any of the following reasons: (1) Authentication failed due to invalid credentials with brokers older than 1.0.0, (2) Firewall blocking Kafka TLS traffic (eg it may only allow HTTPS traffic), (3) Transient network issue.
2024-07-18T14:23:02.993Z  WARN 7 --- [d5c37afaa-0-C-1] org.apache.kafka.clients.NetworkClient   : [Consumer clientId=consumer-case-management-group-3, groupId=case-management-group] Bootstrap broker 10.0.30.108:9092 (id: -1 rack: null) disconnected
Editor is loading...
Leave a Comment