Collects metrics for the Sonar instance at: http://sonar.spring.io

Build: #3594 failed

Job: Default Job failed

Stages & jobs

  1. Default Stage

Build log

The build generated 18,548 lines of output.The output is too long and has been truncated to the last 1,000 lines. Download or view full build log

12-May-2021 02:37:08             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             ... 9 more
12-May-2021 02:37:08     Caused by: org.springframework.messaging.MessageDeliveryException: failed to send Message to channel 'null'; nested exception is java.lang.RuntimeException: intended
12-May-2021 02:37:08             at org.springframework.integration.support.utils.IntegrationUtils.wrapInDeliveryExceptionIfNecessary(IntegrationUtils.java:167) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:339) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.messaging.core.GenericMessagingTemplate.doSendAndReceive(GenericMessagingTemplate.java:233) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.messaging.core.GenericMessagingTemplate.doSendAndReceive(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.messaging.core.AbstractMessagingTemplate.sendAndReceive(AbstractMessagingTemplate.java:46) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.integration.core.MessagingTemplate.sendAndReceive(MessagingTemplate.java:97) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.integration.gateway.MessagingGatewaySupport.doSendAndReceive(MessagingGatewaySupport.java:521) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.integration.gateway.MessagingGatewaySupport.sendAndReceiveMessage(MessagingGatewaySupport.java:491) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.integration.kafka.inbound.KafkaInboundGateway.access$400(KafkaInboundGateway.java:73) ~[main/:?]
12-May-2021 02:37:08             at org.springframework.integration.kafka.inbound.KafkaInboundGateway$IntegrationRecordMessageListener.onMessage(KafkaInboundGateway.java:295) ~[main/:?]
12-May-2021 02:37:08             at org.springframework.integration.kafka.inbound.KafkaInboundGateway$IntegrationRecordMessageListener.onMessage(KafkaInboundGateway.java:266) ~[main/:?]
12-May-2021 02:37:08             at org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.lambda$onMessage$0(RetryingMessageListenerAdapter.java:123) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:329) ~[spring-retry-1.3.1.jar:?]
12-May-2021 02:37:08             at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:255) ~[spring-retry-1.3.1.jar:?]
12-May-2021 02:37:08             at org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.onMessage(RetryingMessageListenerAdapter.java:117) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.onMessage(RetryingMessageListenerAdapter.java:41) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             ... 9 more
12-May-2021 02:37:08     Caused by: java.lang.RuntimeException: intended
12-May-2021 02:37:08             at org.springframework.integration.kafka.inbound.InboundGatewayTests$6.doSend(InboundGatewayTests.java:387) ~[test/:?]
12-May-2021 02:37:08             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.messaging.core.GenericMessagingTemplate.doSendAndReceive(GenericMessagingTemplate.java:233) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.messaging.core.GenericMessagingTemplate.doSendAndReceive(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.messaging.core.AbstractMessagingTemplate.sendAndReceive(AbstractMessagingTemplate.java:46) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.integration.core.MessagingTemplate.sendAndReceive(MessagingTemplate.java:97) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.integration.gateway.MessagingGatewaySupport.doSendAndReceive(MessagingGatewaySupport.java:521) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.integration.gateway.MessagingGatewaySupport.sendAndReceiveMessage(MessagingGatewaySupport.java:491) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.integration.kafka.inbound.KafkaInboundGateway.access$400(KafkaInboundGateway.java:73) ~[main/:?]
12-May-2021 02:37:08             at org.springframework.integration.kafka.inbound.KafkaInboundGateway$IntegrationRecordMessageListener.onMessage(KafkaInboundGateway.java:295) ~[main/:?]
12-May-2021 02:37:08             at org.springframework.integration.kafka.inbound.KafkaInboundGateway$IntegrationRecordMessageListener.onMessage(KafkaInboundGateway.java:266) ~[main/:?]
12-May-2021 02:37:08             at org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.lambda$onMessage$0(RetryingMessageListenerAdapter.java:123) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.retry.support.RetryTemplate.doExecute(RetryTemplate.java:329) ~[spring-retry-1.3.1.jar:?]
12-May-2021 02:37:08             at org.springframework.retry.support.RetryTemplate.execute(RetryTemplate.java:255) ~[spring-retry-1.3.1.jar:?]
12-May-2021 02:37:08             at org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.onMessage(RetryingMessageListenerAdapter.java:117) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter.onMessage(RetryingMessageListenerAdapter.java:41) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:08             ... 9 more
12-May-2021 02:37:08
12-May-2021 02:37:08 InboundGatewayTests > testInbound() STANDARD_OUT
12-May-2021 02:37:08     2021-05-12 02:37:06,635  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:06,637  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:06,788  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:06,884  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:06,890  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:07,251  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08
12-May-2021 02:37:08 InboundGatewayTests > testInboundRetryErrorRecover() STANDARD_OUT
12-May-2021 02:37:08     2021-05-12 02:37:07,559  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08
12-May-2021 02:37:08 InboundGatewayTests STANDARD_OUT
12-May-2021 02:37:08     2021-05-12 02:37:07,652  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:07,862  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:07,863  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:07,962  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:07,986  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:07,987  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:07,987  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:07,987  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,062  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,063  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,064  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,087  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,087  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,117  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,137  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,138  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,163  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,165  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,264  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,288  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,402  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,402  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,402  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,479  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,479  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,480  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,531  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,580  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,730  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,805  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,853  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,881  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:08     2021-05-12 02:37:08,903  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:09     2021-05-12 02:37:08,980  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:09     2021-05-12 02:37:08,981  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:09     2021-05-12 02:37:08,983  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:09     2021-05-12 02:37:08,983  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:09     2021-05-12 02:37:08,987  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:09
12-May-2021 02:37:09 > Task :spring-integration-mail:test
12-May-2021 02:37:09 Finished generating test XML results (0.002 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-mail/build/test-results/test
12-May-2021 02:37:09 Generating HTML test report...
12-May-2021 02:37:09 Finished generating test html results (0.007 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-mail/build/reports/tests/test
12-May-2021 02:37:09 Stored cache entry for task ':spring-integration-mail:test' with cache key 5b721683cdb46aa0959fe0db2a120901
12-May-2021 02:37:09 :spring-integration-mail:test (Thread[Daemon worker,5,main]) completed. Took 47.845 secs.
12-May-2021 02:37:09 :spring-integration-mail:jacocoTestReport (Thread[Daemon worker,5,main]) started.
12-May-2021 02:37:09
12-May-2021 02:37:09 > Task :spring-integration-mail:jacocoTestReport
12-May-2021 02:37:09 Build cache key for task ':spring-integration-mail:jacocoTestReport' is 48ab89bdb4b96652d63e5f70c1472a67
12-May-2021 02:37:09 Task ':spring-integration-mail:jacocoTestReport' is not up-to-date because:
12-May-2021 02:37:09   No history is available.
12-May-2021 02:37:09 [ant:jacocoReport] Loading execution data file /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-mail/build/jacoco.exec
12-May-2021 02:37:09 [ant:jacocoReport] Writing bundle 'spring-integration-mail' with 33 classes
12-May-2021 02:37:09 Stored cache entry for task ':spring-integration-mail:jacocoTestReport' with cache key 48ab89bdb4b96652d63e5f70c1472a67
12-May-2021 02:37:09 :spring-integration-mail:jacocoTestReport (Thread[Daemon worker,5,main]) completed. Took 0.045 secs.
12-May-2021 02:37:09 Gradle Test Executor 15 finished executing tests.
12-May-2021 02:37:09
12-May-2021 02:37:09 > Task :spring-integration-jpa:test
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > getStudent STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_ where studentdom0_.rollNumber=?
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > persistStudentUsingMerge STANDARD_OUT
12-May-2021 02:37:09     Hibernate: call next value for student_sequence
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > testJpaRepositoryAsService STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_ where studentdom0_.gender=?
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > testUpdatingGatewayInsideChain STANDARD_OUT
12-May-2021 02:37:09     Hibernate: call next value for student_sequence
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > getStudentStudentWithPositionalParameters STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_ where studentdom0_.firstName=? and studentdom0_.lastName=?
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > getAllStudentsWithMaxNumberOfRecords STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_ limit ? offset ?
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > getStudentWithException STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > persistStudent STANDARD_OUT
12-May-2021 02:37:09     Hibernate: call next value for student_sequence
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > getAllStudentsStartingFromGivenRecord STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > testRetrievingGatewayInsideChain STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_ where studentdom0_.rollNumber=?
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayTests > getAllStudents STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayIntegrationTests STANDARD_OUT
12-May-2021 02:37:09     Hibernate: create table Student (rollNumber bigint not null, dateOfBirth date, firstName varchar(255), gender varchar(255), lastName varchar(255), lastUpdated timestamp, primary key (rollNumber))
12-May-2021 02:37:09     Hibernate: create table StudentReadStatus (rollNumber integer not null, readAt timestamp, primary key (rollNumber))
12-May-2021 02:37:09     Hibernate: create sequence student_sequence start with 1004 increment by 1
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayIntegrationTests > testFindByPayloadType STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_0_, studentdom0_.dateOfBirth as dateofbi2_0_0_, studentdom0_.firstName as firstnam3_0_0_, studentdom0_.gender as gender4_0_0_, studentdom0_.lastName as lastname5_0_0_, studentdom0_.lastUpdated as lastupda6_0_0_ from Student studentdom0_ where studentdom0_.rollNumber=?
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayIntegrationTests > testFindByEntityClass STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_0_, studentdom0_.dateOfBirth as dateofbi2_0_0_, studentdom0_.firstName as firstnam3_0_0_, studentdom0_.gender as gender4_0_0_, studentdom0_.lastName as lastname5_0_0_, studentdom0_.lastUpdated as lastupda6_0_0_ from Student studentdom0_ where studentdom0_.rollNumber=?
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayIntegrationTests > retrieveFromSecondRecordAndMaximumOneRecord STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_ limit ? offset ?
12-May-2021 02:37:09     Hibernate: delete from Student where rollNumber=?
12-May-2021 02:37:09     Hibernate: delete from Student where rollNumber=?
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_, studentdom0_.dateOfBirth as dateofbi2_0_, studentdom0_.firstName as firstnam3_0_, studentdom0_.gender as gender4_0_, studentdom0_.lastName as lastname5_0_, studentdom0_.lastUpdated as lastupda6_0_ from Student studentdom0_
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundGatewayIntegrationTests > testFindAndDelete STANDARD_OUT
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_0_, studentdom0_.dateOfBirth as dateofbi2_0_0_, studentdom0_.firstName as firstnam3_0_0_, studentdom0_.gender as gender4_0_0_, studentdom0_.lastName as lastname5_0_0_, studentdom0_.lastUpdated as lastupda6_0_0_ from Student studentdom0_ where studentdom0_.rollNumber=?
12-May-2021 02:37:09     Hibernate: delete from Student where rollNumber=?
12-May-2021 02:37:09     Hibernate: select studentdom0_.rollNumber as rollnumb1_0_0_, studentdom0_.dateOfBirth as dateofbi2_0_0_, studentdom0_.firstName as firstnam3_0_0_, studentdom0_.gender as gender4_0_0_, studentdom0_.lastName as lastname5_0_0_, studentdom0_.lastUpdated as lastupda6_0_0_ from Student studentdom0_ where studentdom0_.rollNumber=?
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundChannelAdapterTests STANDARD_OUT
12-May-2021 02:37:09     Hibernate: create table Student (rollNumber bigint not null, dateOfBirth date, firstName varchar(255), gender varchar(255), lastName varchar(255), lastUpdated timestamp, primary key (rollNumber))
12-May-2021 02:37:09     Hibernate: create table StudentReadStatus (rollNumber integer not null, readAt timestamp, primary key (rollNumber))
12-May-2021 02:37:09     Hibernate: create sequence student_sequence start with 1004 increment by 1
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundChannelAdapterTests > saveEntityWithPersistWithinChain STANDARD_OUT
12-May-2021 02:37:09     Hibernate: call next value for student_sequence
12-May-2021 02:37:09     Hibernate: insert into Student (dateOfBirth, firstName, gender, lastName, lastUpdated, rollNumber) values (?, ?, ?, ?, ?, ?)
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundChannelAdapterTests > saveEntityWithMergeWithoutSpecifyingEntityClass STANDARD_OUT
12-May-2021 02:37:09     Hibernate: call next value for student_sequence
12-May-2021 02:37:09     Hibernate: insert into Student (dateOfBirth, firstName, gender, lastName, lastUpdated, rollNumber) values (?, ?, ?, ?, ?, ?)
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundChannelAdapterTests > saveEntityWithPersist STANDARD_OUT
12-May-2021 02:37:09     Hibernate: call next value for student_sequence
12-May-2021 02:37:09     Hibernate: insert into Student (dateOfBirth, firstName, gender, lastName, lastUpdated, rollNumber) values (?, ?, ?, ?, ?, ?)
12-May-2021 02:37:09
12-May-2021 02:37:09 JpaOutboundChannelAdapterTests > saveEntityWithMerge STANDARD_OUT
12-May-2021 02:37:09     Hibernate: call next value for student_sequence
12-May-2021 02:37:09     Hibernate: insert into Student (dateOfBirth, firstName, gender, lastName, lastUpdated, rollNumber) values (?, ?, ?, ?, ?, ?)
12-May-2021 02:37:09 Finished generating test XML results (0.001 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-jpa/build/test-results/test
12-May-2021 02:37:09 Generating HTML test report...
12-May-2021 02:37:09 Finished generating test html results (0.002 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-jpa/build/reports/tests/test
12-May-2021 02:37:09 Stored cache entry for task ':spring-integration-jpa:test' with cache key 63ecf8cfbfc648944080bcbc156b4548
12-May-2021 02:37:09 :spring-integration-jpa:test (Thread[Execution worker for ':' Thread 2,5,main]) completed. Took 1 mins 0.592 secs.
12-May-2021 02:37:09 :spring-integration-jpa:jacocoTestReport (Thread[Execution worker for ':' Thread 2,5,main]) started.
12-May-2021 02:37:09
12-May-2021 02:37:09 > Task :spring-integration-jpa:jacocoTestReport
12-May-2021 02:37:09 Build cache key for task ':spring-integration-jpa:jacocoTestReport' is bec326201ef694a31acf239996818bf9
12-May-2021 02:37:09 Task ':spring-integration-jpa:jacocoTestReport' is not up-to-date because:
12-May-2021 02:37:09   No history is available.
12-May-2021 02:37:09 [ant:jacocoReport] Loading execution data file /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-jpa/build/jacoco.exec
12-May-2021 02:37:09 [ant:jacocoReport] Writing bundle 'spring-integration-jpa' with 30 classes
12-May-2021 02:37:09 Stored cache entry for task ':spring-integration-jpa:jacocoTestReport' with cache key bec326201ef694a31acf239996818bf9
12-May-2021 02:37:09 :spring-integration-jpa:jacocoTestReport (Thread[Execution worker for ':' Thread 2,5,main]) completed. Took 0.046 secs.
12-May-2021 02:37:11
12-May-2021 02:37:11 > Task :spring-integration-kafka:test
12-May-2021 02:37:11     2021-05-12 02:37:09,082  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,483  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,485  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,557  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,606  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,683  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,706  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,784  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,785  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,784  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,786  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,933  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,935  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:09,939  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,441  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,588  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,638  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,660  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,686  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,687  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,759  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,787  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,787  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,792  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:10,811  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11
12-May-2021 02:37:11 MessageSourceIntegrationTests STANDARD_OUT
12-May-2021 02:37:11     2021-05-12 02:37:10,987  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,016  WARN kafka.server.BrokerMetadataCheckpoint [Test worker] : No meta.properties file under dir /tmp/spring.kafka.c3feb8b5-d87e-419e-99cb-4df9701103526041724980916134062/meta.properties
12-May-2021 02:37:11     2021-05-12 02:37:11,037  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11
12-May-2021 02:37:11 MessageSourceIntegrationTests > testSource() STANDARD_OUT
12-May-2021 02:37:11     2021-05-12 02:37:11,150  WARN org.springframework.integration.kafka.inbound.KafkaMessageSource [Test worker] : max.poll.records' has been forced from 2 to 1, to avoid having to seek after each record
12-May-2021 02:37:11
12-May-2021 02:37:11 MessageSourceIntegrationTests STANDARD_OUT
12-May-2021 02:37:11     2021-05-12 02:37:11,343  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,512  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,540  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,640  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,689  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,713  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,740  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,790  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,864  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:11     2021-05-12 02:37:11,890  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:11,990  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:11,995  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:12,141  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:12,345  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:12,515  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:12,541  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:12,593  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:12,665  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:12,743  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:12,766  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:12     2021-05-12 02:37:12,792  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:12,992  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:12,992  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:12,992  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:12,997  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:13,043  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:13,198  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:13,446  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:13,494  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:13,518  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:13,668  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:13,695  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:13,719  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:13     2021-05-12 02:37:13,745  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:13,995  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:14
12-May-2021 02:37:14 KafkaMessageDrivenChannelAdapterParserTests STANDARD_OUT
12-May-2021 02:37:14     2021-05-12 02:37:14,150  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,195  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,195  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,195  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,351  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,399  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,521  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,548  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,635  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,685  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,785  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:14     2021-05-12 02:37:14,835  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:15     2021-05-12 02:37:14,986  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:15
12-May-2021 02:37:15 KafkaOutboundGatewayParserTests STANDARD_OUT
12-May-2021 02:37:15     2021-05-12 02:37:15,136  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:15     2021-05-12 02:37:15,136  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:15     2021-05-12 02:37:15,136  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:15
12-May-2021 02:37:15 KafkaInboundChannelAdapterParserTests STANDARD_OUT
12-May-2021 02:37:15     2021-05-12 02:37:15,336  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:15     2021-05-12 02:37:15,337  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:15     2021-05-12 02:37:15,437  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:15
12-May-2021 02:37:15 KafkaInboundGatewayTests STANDARD_OUT
12-May-2021 02:37:15     2021-05-12 02:37:15,553  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:15
12-May-2021 02:37:15 KafkaOutboundAdapterParserTests STANDARD_OUT
12-May-2021 02:37:15     2021-05-12 02:37:15,588  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:15     2021-05-12 02:37:15,588  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:15
12-May-2021 02:37:15 KafkaOutboundAdapterParserTests > testSyncMode() STANDARD_OUT
12-May-2021 02:37:15     2021-05-12 02:37:15,688  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:15     2021-05-12 02:37:15,688  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:15     2021-05-12 02:37:15,773 ERROR org.springframework.kafka.support.LoggingProducerListener [pool-26-thread-1] : Exception thrown when sending a message with key='null' and payload='foo' to topic foo:
12-May-2021 02:37:15     java.lang.RuntimeException: Async Producer Mock exception
12-May-2021 02:37:15             at org.springframework.integration.kafka.config.xml.KafkaOutboundAdapterParserTests.lambda$testSyncMode$0(KafkaOutboundAdapterParserTests.java:130) ~[test/:?]
12-May-2021 02:37:15             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
12-May-2021 02:37:15             at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
12-May-2021 02:37:15             at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
12-May-2021 02:37:15             at java.lang.Thread.run(Thread.java:829) [?:?]
12-May-2021 02:37:15     2021-05-12 02:37:15,838  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:16
12-May-2021 02:37:16 ChannelParserTests STANDARD_OUT
12-May-2021 02:37:16     2021-05-12 02:37:16,039  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,090  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:16
12-May-2021 02:37:16 AllXmlTests STANDARD_OUT
12-May-2021 02:37:16     2021-05-12 02:37:16,238  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,309  WARN kafka.server.BrokerMetadataCheckpoint [Test worker] : No meta.properties file under dir /tmp/spring.kafka.707624e8-6ece-4617-b11b-098760f0364311746658386760799054/meta.properties
12-May-2021 02:37:16     2021-05-12 02:37:16,339  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,442  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,443  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,491  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,494  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,542  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,594  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,658  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:16     2021-05-12 02:37:16,702  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,003  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,160  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,211  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,261  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,362  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,362  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,411  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,462  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,497  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,511  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,562  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,661  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:17     2021-05-12 02:37:17,887  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,063  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,207  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,314  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,314  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,364  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,464  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,464  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,499  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,614  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,615  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,615  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:18     2021-05-12 02:37:18,664  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,091  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,260  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,267  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,267  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,317  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:19
12-May-2021 02:37:19 KafkaDslTests STANDARD_OUT
12-May-2021 02:37:19     2021-05-12 02:37:19,366  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,400  WARN kafka.server.BrokerMetadataCheckpoint [Test worker] : No meta.properties file under dir /tmp/spring.kafka.703a5376-b68e-4d33-bcc1-315a52cac4a314326707012943047674/meta.properties
12-May-2021 02:37:19     2021-05-12 02:37:19,451  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,518  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,518  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,668  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,768  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,818  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,867  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:19     2021-05-12 02:37:19,927  WARN org.springframework.integration.kafka.inbound.KafkaMessageSource [Test worker] : max.poll.records' has been forced from unspecified to 1, to avoid having to seek after each record
12-May-2021 02:37:19     2021-05-12 02:37:19,940  WARN org.springframework.integration.kafka.inbound.KafkaMessageSource [Test worker] : max.poll.records' has been forced from unspecified to 1, to avoid having to seek after each record
12-May-2021 02:37:20 WARNING: An illegal reflective access operation has occurred
12-May-2021 02:37:20 WARNING: Illegal reflective access by org.springframework.util.ReflectionUtils (file:/opt/users/bamboo/.gradle/caches/modules-2/files-2.1/org.springframework/spring-core/5.3.7-SNAPSHOT/c5b4e78a93fb7d9706c0cffe7354230c5b4372df/spring-core-5.3.7-SNAPSHOT.jar) to constructor java.lang.invoke.MethodHandles$Lookup(java.lang.Class)
12-May-2021 02:37:20 WARNING: Please consider reporting this to the maintainers of org.springframework.util.ReflectionUtils
12-May-2021 02:37:20 WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations
12-May-2021 02:37:20 WARNING: All illegal access operations will be denied in a future release
12-May-2021 02:37:20     2021-05-12 02:37:20,044  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:20
12-May-2021 02:37:20 KafkaDslTests > testGateways() STANDARD_OUT
12-May-2021 02:37:20     2021-05-12 02:37:20,170  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:20
12-May-2021 02:37:20 KafkaDslTests > channels(MessageChannel, PollableKafkaChannel, PollableKafkaChannel) STANDARD_OUT
12-May-2021 02:37:20     2021-05-12 02:37:20,268  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,269  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,315  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,370  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,420  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,458  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,470  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,676  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,721  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,770  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:20     2021-05-12 02:37:20,777  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,147  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,278  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,323  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,371  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,371  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,411  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,518  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,522  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,528  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,577  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,629  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,774  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:21     2021-05-12 02:37:21,872  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,224  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,281  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,300  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,373  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,381  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,476  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,532  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,564  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,571  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,579  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,675  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,776  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:22     2021-05-12 02:37:22,875  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,132  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,176  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,275  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:23
12-May-2021 02:37:23 KafkaDslTests > testKafkaAdapters() STANDARD_OUT
12-May-2021 02:37:23     2021-05-12 02:37:23,353  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,481  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,518  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,534  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,584  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,678  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,679  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,724  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,779  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:23     2021-05-12 02:37:23,964 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
12-May-2021 02:37:23     org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow', failedMessage=GenericMessage [payload=foo, headers={sequenceNumber=101, sequenceSize=0, foo=bar, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=101, kafka_receivedTopic=test-topic2, kafka_offset=100, [email protected]3db092a, correlationId=de263cda-79f1-2a13-effe-db8dfc9a6163, kafka_receivedPartitionId=0, kafka_receivedTimestamp=1487694048644, kafka_acknowledgment=Acknowledgment for ConsumerRecord(topic = test-topic2, partition = 0, leaderEpoch = 0, offset = 100, CreateTime = 1487694048644, serialized key size = 4, serialized value size = 3, headers = RecordHeaders(headers = [RecordHeader(key = sequenceNumber, value = [49, 48, 49]), RecordHeader(key = sequenceSize, value = [48]), RecordHeader(key = foo, value = [98, 97, 114]), RecordHeader(key = correlationId, value = [34, 100, 101, 50, 54, 51, 99, 100, 97, 45, 55, 57, 102, 49, 45, 50, 97, 49, 51, 45, 101, 102, 102, 101, 45, 100, 98, 56, 100, 102, 99, 57, 97, 54, 49, 54, 51, 34]), RecordHeader(key = spring_json_header_types, value = [123, 34, 115, 101, 113, 117, 101, 110, 99, 101, 78, 117, 109, 98, 101, 114, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 115, 101, 113, 117, 101, 110, 99, 101, 83, 105, 122, 101, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 102, 111, 111, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 107, 97, 102, 107, 97, 95, 102, 117, 116, 117, 114, 101, 84, 111, 107, 101, 110, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 99, 111, 114, 114, 101, 108, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 106, 97, 118, 97, 46, 117, 116, 105, 108, 46, 85, 85, 73, 68, 34, 125])], isReadOnly = false), key = 101, value = foo), kafka_groupId=test1}]
12-May-2021 02:37:23             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:23             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
12-May-2021 02:37:23             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
12-May-2021 02:37:23             at java.lang.Thread.run(Thread.java:829) [?:?]
12-May-2021 02:37:24     Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow', failedMessage=GenericMessage [payload=foo, headers={sequenceNumber=101, sequenceSize=0, foo=bar, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=101, kafka_receivedTopic=test-topic2, kafka_offset=100, [email protected]3db092a, correlationId=de263cda-79f1-2a13-effe-db8dfc9a6163, kafka_receivedPartitionId=0, kafka_receivedTimestamp=1487694048644, kafka_acknowledgment=Acknowledgment for ConsumerRecord(topic = test-topic2, partition = 0, leaderEpoch = 0, offset = 100, CreateTime = 1487694048644, serialized key size = 4, serialized value size = 3, headers = RecordHeaders(headers = [RecordHeader(key = sequenceNumber, value = [49, 48, 49]), RecordHeader(key = sequenceSize, value = [48]), RecordHeader(key = foo, value = [98, 97, 114]), RecordHeader(key = correlationId, value = [34, 100, 101, 50, 54, 51, 99, 100, 97, 45, 55, 57, 102, 49, 45, 50, 97, 49, 51, 45, 101, 102, 102, 101, 45, 100, 98, 56, 100, 102, 99, 57, 97, 54, 49, 54, 51, 34]), RecordHeader(key = spring_json_header_types, value = [123, 34, 115, 101, 113, 117, 101, 110, 99, 101, 78, 117, 109, 98, 101, 114, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 115, 101, 113, 117, 101, 110, 99, 101, 83, 105, 122, 101, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 102, 111, 111, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 107, 97, 102, 107, 97, 95, 102, 117, 116, 117, 114, 101, 84, 111, 107, 101, 110, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 99, 111, 114, 114, 101, 108, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 106, 97, 118, 97, 46, 117, 116, 105, 108, 46, 85, 85, 73, 68, 34, 125])], isReadOnly = false), key = 101, value = foo), kafka_groupId=test1}]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             ... 9 more
12-May-2021 02:37:24     Caused by: org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow'
12-May-2021 02:37:24             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             ... 9 more
12-May-2021 02:37:24     2021-05-12 02:37:23,979  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,073 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
12-May-2021 02:37:24     org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow', failedMessage=GenericMessage [payload=foo, headers={sequenceNumber=101, sequenceSize=0, foo=bar, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=101, kafka_receivedTopic=test-topic2, kafka_offset=100, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsume[email protected], correlationId=de263cda-79f1-2a13-effe-db8dfc9a6163, kafka_receivedPartitionId=0, kafka_receivedTimestamp=1487694048644, kafka_acknowledgment=Acknowledgment for ConsumerRecord(topic = test-topic2, partition = 0, leaderEpoch = 0, offset = 100, CreateTime = 1487694048644, serialized key size = 4, serialized value size = 3, headers = RecordHeaders(headers = [RecordHeader(key = sequenceNumber, value = [49, 48, 49]), RecordHeader(key = sequenceSize, value = [48]), RecordHeader(key = foo, value = [98, 97, 114]), RecordHeader(key = correlationId, value = [34, 100, 101, 50, 54, 51, 99, 100, 97, 45, 55, 57, 102, 49, 45, 50, 97, 49, 51, 45, 101, 102, 102, 101, 45, 100, 98, 56, 100, 102, 99, 57, 97, 54, 49, 54, 51, 34]), RecordHeader(key = spring_json_header_types, value = [123, 34, 115, 101, 113, 117, 101, 110, 99, 101, 78, 117, 109, 98, 101, 114, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 115, 101, 113, 117, 101, 110, 99, 101, 83, 105, 122, 101, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 102, 111, 111, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 107, 97, 102, 107, 97, 95, 102, 117, 116, 117, 114, 101, 84, 111, 107, 101, 110, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 99, 111, 114, 114, 101, 108, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 106, 97, 118, 97, 46, 117, 116, 105, 108, 46, 85, 85, 73, 68, 34, 125])], isReadOnly = false), key = 101, value = foo), kafka_groupId=test1}]
12-May-2021 02:37:24             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
12-May-2021 02:37:24             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
12-May-2021 02:37:24             at java.lang.Thread.run(Thread.java:829) [?:?]
12-May-2021 02:37:24     Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow', failedMessage=GenericMessage [payload=foo, headers={sequenceNumber=101, sequenceSize=0, foo=bar, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=101, kafka_receivedTopic=test-topic2, kafka_offset=100, [email protected]3db092a, correlationId=de263cda-79f1-2a13-effe-db8dfc9a6163, kafka_receivedPartitionId=0, kafka_receivedTimestamp=1487694048644, kafka_acknowledgment=Acknowledgment for ConsumerRecord(topic = test-topic2, partition = 0, leaderEpoch = 0, offset = 100, CreateTime = 1487694048644, serialized key size = 4, serialized value size = 3, headers = RecordHeaders(headers = [RecordHeader(key = sequenceNumber, value = [49, 48, 49]), RecordHeader(key = sequenceSize, value = [48]), RecordHeader(key = foo, value = [98, 97, 114]), RecordHeader(key = correlationId, value = [34, 100, 101, 50, 54, 51, 99, 100, 97, 45, 55, 57, 102, 49, 45, 50, 97, 49, 51, 45, 101, 102, 102, 101, 45, 100, 98, 56, 100, 102, 99, 57, 97, 54, 49, 54, 51, 34]), RecordHeader(key = spring_json_header_types, value = [123, 34, 115, 101, 113, 117, 101, 110, 99, 101, 78, 117, 109, 98, 101, 114, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 115, 101, 113, 117, 101, 110, 99, 101, 83, 105, 122, 101, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 102, 111, 111, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 107, 97, 102, 107, 97, 95, 102, 117, 116, 117, 114, 101, 84, 111, 107, 101, 110, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 99, 111, 114, 114, 101, 108, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 106, 97, 118, 97, 46, 117, 116, 105, 108, 46, 85, 85, 73, 68, 34, 125])], isReadOnly = false), key = 101, value = foo), kafka_groupId=test1}]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             ... 9 more
12-May-2021 02:37:24     Caused by: org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow'
12-May-2021 02:37:24             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             ... 9 more
12-May-2021 02:37:24     2021-05-12 02:37:24,086  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,177  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,180 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
12-May-2021 02:37:24     org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow', failedMessage=GenericMessage [payload=foo, headers={sequenceNumber=101, sequenceSize=0, foo=bar, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=101, kafka_receivedTopic=test-topic2, kafka_offset=100, [email protected]3db092a, correlationId=de263cda-79f1-2a13-effe-db8dfc9a6163, kafka_receivedPartitionId=0, kafka_receivedTimestamp=1487694048644, kafka_acknowledgment=Acknowledgment for ConsumerRecord(topic = test-topic2, partition = 0, leaderEpoch = 0, offset = 100, CreateTime = 1487694048644, serialized key size = 4, serialized value size = 3, headers = RecordHeaders(headers = [RecordHeader(key = sequenceNumber, value = [49, 48, 49]), RecordHeader(key = sequenceSize, value = [48]), RecordHeader(key = foo, value = [98, 97, 114]), RecordHeader(key = correlationId, value = [34, 100, 101, 50, 54, 51, 99, 100, 97, 45, 55, 57, 102, 49, 45, 50, 97, 49, 51, 45, 101, 102, 102, 101, 45, 100, 98, 56, 100, 102, 99, 57, 97, 54, 49, 54, 51, 34]), RecordHeader(key = spring_json_header_types, value = [123, 34, 115, 101, 113, 117, 101, 110, 99, 101, 78, 117, 109, 98, 101, 114, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 115, 101, 113, 117, 101, 110, 99, 101, 83, 105, 122, 101, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 102, 111, 111, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 107, 97, 102, 107, 97, 95, 102, 117, 116, 117, 114, 101, 84, 111, 107, 101, 110, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 99, 111, 114, 114, 101, 108, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 106, 97, 118, 97, 46, 117, 116, 105, 108, 46, 85, 85, 73, 68, 34, 125])], isReadOnly = false), key = 101, value = foo), kafka_groupId=test1}]
12-May-2021 02:37:24             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
12-May-2021 02:37:24             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
12-May-2021 02:37:24             at java.lang.Thread.run(Thread.java:829) [?:?]
12-May-2021 02:37:24     Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow', failedMessage=GenericMessage [payload=foo, headers={sequenceNumber=101, sequenceSize=0, foo=bar, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=101, kafka_receivedTopic=test-topic2, kafka_offset=100, [email protected]3db092a, correlationId=de263cda-79f1-2a13-effe-db8dfc9a6163, kafka_receivedPartitionId=0, kafka_receivedTimestamp=1487694048644, kafka_acknowledgment=Acknowledgment for ConsumerRecord(topic = test-topic2, partition = 0, leaderEpoch = 0, offset = 100, CreateTime = 1487694048644, serialized key size = 4, serialized value size = 3, headers = RecordHeaders(headers = [RecordHeader(key = sequenceNumber, value = [49, 48, 49]), RecordHeader(key = sequenceSize, value = [48]), RecordHeader(key = foo, value = [98, 97, 114]), RecordHeader(key = correlationId, value = [34, 100, 101, 50, 54, 51, 99, 100, 97, 45, 55, 57, 102, 49, 45, 50, 97, 49, 51, 45, 101, 102, 102, 101, 45, 100, 98, 56, 100, 102, 99, 57, 97, 54, 49, 54, 51, 34]), RecordHeader(key = spring_json_header_types, value = [123, 34, 115, 101, 113, 117, 101, 110, 99, 101, 78, 117, 109, 98, 101, 114, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 115, 101, 113, 117, 101, 110, 99, 101, 83, 105, 122, 101, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 102, 111, 111, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 107, 97, 102, 107, 97, 95, 102, 117, 116, 117, 114, 101, 84, 111, 107, 101, 110, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 99, 111, 114, 114, 101, 108, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 106, 97, 118, 97, 46, 117, 116, 105, 108, 46, 85, 85, 73, 68, 34, 125])], isReadOnly = false), key = 101, value = foo), kafka_groupId=test1}]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             ... 9 more
12-May-2021 02:37:24     Caused by: org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow'
12-May-2021 02:37:24             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             ... 9 more
12-May-2021 02:37:24     2021-05-12 02:37:24,229  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:24
12-May-2021 02:37:24 KafkaDslTests STANDARD_OUT
12-May-2021 02:37:24     2021-05-12 02:37:24,285 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
12-May-2021 02:37:24     org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow', failedMessage=GenericMessage [payload=foo, headers={sequenceNumber=101, sequenceSize=0, foo=bar, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=101, kafka_receivedTopic=test-topic2, kafka_offset=100, [email protected]3db092a, correlationId=de263cda-79f1-2a13-effe-db8dfc9a6163, kafka_receivedPartitionId=0, kafka_receivedTimestamp=1487694048644, kafka_acknowledgment=Acknowledgment for ConsumerRecord(topic = test-topic2, partition = 0, leaderEpoch = 0, offset = 100, CreateTime = 1487694048644, serialized key size = 4, serialized value size = 3, headers = RecordHeaders(headers = [RecordHeader(key = sequenceNumber, value = [49, 48, 49]), RecordHeader(key = sequenceSize, value = [48]), RecordHeader(key = foo, value = [98, 97, 114]), RecordHeader(key = correlationId, value = [34, 100, 101, 50, 54, 51, 99, 100, 97, 45, 55, 57, 102, 49, 45, 50, 97, 49, 51, 45, 101, 102, 102, 101, 45, 100, 98, 56, 100, 102, 99, 57, 97, 54, 49, 54, 51, 34]), RecordHeader(key = spring_json_header_types, value = [123, 34, 115, 101, 113, 117, 101, 110, 99, 101, 78, 117, 109, 98, 101, 114, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 115, 101, 113, 117, 101, 110, 99, 101, 83, 105, 122, 101, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 102, 111, 111, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 107, 97, 102, 107, 97, 95, 102, 117, 116, 117, 114, 101, 84, 111, 107, 101, 110, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 99, 111, 114, 114, 101, 108, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 106, 97, 118, 97, 46, 117, 116, 105, 108, 46, 85, 85, 73, 68, 34, 125])], isReadOnly = false), key = 101, value = foo), kafka_groupId=test1}]
12-May-2021 02:37:24             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
12-May-2021 02:37:24             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
12-May-2021 02:37:24             at java.lang.Thread.run(Thread.java:829) [?:?]
12-May-2021 02:37:24     Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener failed; nested exception is org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow', failedMessage=GenericMessage [payload=foo, headers={sequenceNumber=101, sequenceSize=0, foo=bar, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=101, kafka_receivedTopic=test-topic2, kafka_offset=100, [email protected]3db092a, correlationId=de263cda-79f1-2a13-effe-db8dfc9a6163, kafka_receivedPartitionId=0, kafka_receivedTimestamp=1487694048644, kafka_acknowledgment=Acknowledgment for ConsumerRecord(topic = test-topic2, partition = 0, leaderEpoch = 0, offset = 100, CreateTime = 1487694048644, serialized key size = 4, serialized value size = 3, headers = RecordHeaders(headers = [RecordHeader(key = sequenceNumber, value = [49, 48, 49]), RecordHeader(key = sequenceSize, value = [48]), RecordHeader(key = foo, value = [98, 97, 114]), RecordHeader(key = correlationId, value = [34, 100, 101, 50, 54, 51, 99, 100, 97, 45, 55, 57, 102, 49, 45, 50, 97, 49, 51, 45, 101, 102, 102, 101, 45, 100, 98, 56, 100, 102, 99, 57, 97, 54, 49, 54, 51, 34]), RecordHeader(key = spring_json_header_types, value = [123, 34, 115, 101, 113, 117, 101, 110, 99, 101, 78, 117, 109, 98, 101, 114, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 115, 101, 113, 117, 101, 110, 99, 101, 83, 105, 122, 101, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 73, 110, 116, 101, 103, 101, 114, 34, 44, 34, 102, 111, 111, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 107, 97, 102, 107, 97, 95, 102, 117, 116, 117, 114, 101, 84, 111, 107, 101, 110, 34, 58, 34, 106, 97, 118, 97, 46, 108, 97, 110, 103, 46, 83, 116, 114, 105, 110, 103, 34, 44, 34, 99, 111, 114, 114, 101, 108, 97, 116, 105, 111, 110, 73, 100, 34, 58, 34, 106, 97, 118, 97, 46, 117, 116, 105, 108, 46, 85, 85, 73, 68, 34, 125])], isReadOnly = false), key = 101, value = foo), kafka_groupId=test1}]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             ... 9 more
12-May-2021 02:37:24     Caused by: org.springframework.integration.MessageRejectedException: message has been rejected in filter: bean 'topic2ListenerFromKafkaFlow.filter#0' for component 'topic2ListenerFromKafkaFlow.org.springframework.integration.config.ConsumerEndpointFactoryBean#0'; defined in: 'org.springframework.integration.kafka.dsl.KafkaDslTests$ContextConfiguration'; from source: 'bean method topic2ListenerFromKafkaFlow'
12-May-2021 02:37:24             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:24             ... 9 more
12-May-2021 02:37:24     2021-05-12 02:37:24,305  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,422  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,576  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,581  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,583  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,586  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,638  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,731  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:24     2021-05-12 02:37:24,781  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:24,982  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,190  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,279  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,331  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,428  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,485  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,507  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,525  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,583  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,591  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,633  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,684  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:25     2021-05-12 02:37:25,788  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,042  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,184  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,280  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,282  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,409  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,435  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,494  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,533  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,578  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,687  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,740  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,786  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:26     2021-05-12 02:37:26,837  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,094  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,182  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,286  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,384  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:27
12-May-2021 02:37:27 ChannelTests STANDARD_OUT
12-May-2021 02:37:27     2021-05-12 02:37:27,462  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,477  WARN kafka.server.BrokerMetadataCheckpoint [Test worker] : No meta.properties file under dir /tmp/spring.kafka.3fc3bfca-dd47-4fbf-9f9b-d3bec7eb12bf4629302924121832553/meta.properties
12-May-2021 02:37:27     2021-05-12 02:37:27,481  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,539  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,546  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,589  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,663  WARN org.springframework.integration.kafka.inbound.KafkaMessageSource [Test worker] : max.poll.records' has been forced from unspecified to 1, to avoid having to seek after each record
12-May-2021 02:37:27
12-May-2021 02:37:27 ChannelTests > pubSub(SubscribableChannel) STANDARD_OUT
12-May-2021 02:37:27     2021-05-12 02:37:27,736  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,793  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:27
12-May-2021 02:37:27 KafkaProducerMessageHandlerTests STANDARD_OUT
12-May-2021 02:37:27     2021-05-12 02:37:27,840  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,871  WARN kafka.server.BrokerMetadataCheckpoint [Test worker] : No meta.properties file under dir /tmp/spring.kafka.26eeb410-eba1-4732-bfb7-73e74e5ab7fc13199716093980492283/meta.properties
12-May-2021 02:37:27     2021-05-12 02:37:27,940  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:27     2021-05-12 02:37:27,964  WARN org.apache.kafka.common.utils.AppInfoParser [Test worker] : Error registering AppInfo mbean
12-May-2021 02:37:27     javax.management.InstanceAlreadyExistsException: kafka.server:type=app-info,id=0
12-May-2021 02:37:27             at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:436) ~[?:?]
12-May-2021 02:37:27             at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1855) ~[?:?]
12-May-2021 02:37:27             at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:955) ~[?:?]
12-May-2021 02:37:27             at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:890) ~[?:?]
12-May-2021 02:37:27             at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:320) ~[?:?]
12-May-2021 02:37:27             at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522) ~[?:?]
12-May-2021 02:37:27             at org.apache.kafka.common.utils.AppInfoParser.registerAppInfo(AppInfoParser.java:64) ~[kafka-clients-2.7.0.jar:?]
12-May-2021 02:37:27             at kafka.server.KafkaServer.startup(KafkaServer.scala:393) ~[kafka_2.13-2.7.0.jar:?]
12-May-2021 02:37:27             at kafka.utils.TestUtils$.createServer(TestUtils.scala:161) ~[kafka_2.13-2.7.0-test.jar:?]
12-May-2021 02:37:27             at kafka.utils.TestUtils$.createServer(TestUtils.scala:152) ~[kafka_2.13-2.7.0-test.jar:?]
12-May-2021 02:37:27             at kafka.utils.TestUtils.createServer(TestUtils.scala) ~[kafka_2.13-2.7.0-test.jar:?]
12-May-2021 02:37:27             at org.springframework.kafka.test.EmbeddedKafkaBroker.afterPropertiesSet(EmbeddedKafkaBroker.java:337) ~[spring-kafka-test-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
12-May-2021 02:37:27             at org.springframework.integration.kafka.outbound.KafkaProducerMessageHandlerTests.setup(KafkaProducerMessageHandlerTests.java:136) ~[test/:?]
12-May-2021 02:37:27             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
12-May-2021 02:37:27             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
12-May-2021 02:37:27             at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
12-May-2021 02:37:27             at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
12-May-2021 02:37:27             at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688) ~[junit-platform-commons-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.extension.TimeoutExtension.interceptLifecycleMethod(TimeoutExtension.java:126) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.extension.TimeoutExtension.interceptBeforeAllMethod(TimeoutExtension.java:68) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$invokeBeforeAllMethods$9(ClassBasedTestDescriptor.java:384) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.invokeBeforeAllMethods(ClassBasedTestDescriptor.java:382) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.before(ClassBasedTestDescriptor.java:196) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.before(ClassBasedTestDescriptor.java:78) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:136) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at java.util.ArrayList.forEach(ArrayList.java:1541) ~[?:?]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51) ~[junit-platform-engine-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:108) ~[junit-platform-launcher-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88) ~[junit-platform-launcher-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54) ~[junit-platform-launcher-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67) [junit-platform-launcher-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52) [junit-platform-launcher-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:96) [junit-platform-launcher-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:75) [junit-platform-launcher-1.7.1.jar:1.7.1]
12-May-2021 02:37:27             at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.processAllTestClasses(JUnitPlatformTestClassProcessor.java:99) [gradle-testing-junit-platform-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor$CollectAllTestClassesExecutor.access$000(JUnitPlatformTestClassProcessor.java:79) [gradle-testing-junit-platform-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:75) [gradle-testing-junit-platform-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:61) [gradle-testing-base-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
12-May-2021 02:37:27             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
12-May-2021 02:37:27             at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
12-May-2021 02:37:27             at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
12-May-2021 02:37:27             at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36) [gradle-messaging-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24) [gradle-messaging-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33) [gradle-messaging-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94) [gradle-messaging-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at com.sun.proxy.$Proxy5.stop(Unknown Source) [?:?]
12-May-2021 02:37:27             at org.gradle.api.internal.tasks.testing.worker.TestWorker.stop(TestWorker.java:133) [gradle-testing-base-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
12-May-2021 02:37:27             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
12-May-2021 02:37:27             at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
12-May-2021 02:37:27             at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
12-May-2021 02:37:27             at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36) [gradle-messaging-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24) [gradle-messaging-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:182) [gradle-messaging-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:164) [gradle-messaging-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:414) [gradle-messaging-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64) [gradle-base-services-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:48) [gradle-base-services-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
12-May-2021 02:37:27             at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
12-May-2021 02:37:27             at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56) [gradle-base-services-6.8.2.jar:6.8.2]
12-May-2021 02:37:27             at java.lang.Thread.run(Thread.java:829) [?:?]
12-May-2021 02:37:28     2021-05-12 02:37:28,046  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:28     2021-05-12 02:37:28,141  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:28     2021-05-12 02:37:28,288  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:28
12-May-2021 02:37:28 KafkaProducerMessageHandlerTests > testOutboundGatewayPrPayload() STANDARD_OUT
12-May-2021 02:37:28     2021-05-12 02:37:28,487  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:28     2021-05-12 02:37:28,491  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:28
12-May-2021 02:37:28 KafkaProducerMessageHandlerTests STANDARD_OUT
12-May-2021 02:37:28     2021-05-12 02:37:28,565  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:28
12-May-2021 02:37:28 KafkaProducerMessageHandlerTests > testFlush() STANDARD_OUT
12-May-2021 02:37:28     2021-05-12 02:37:28,586  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:28
12-May-2021 02:37:28 KafkaProducerMessageHandlerTests > testOutboundWithTimestampExpression() STANDARD_OUT
12-May-2021 02:37:28     2021-05-12 02:37:28,695  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:28     2021-05-12 02:37:28,703  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:28
12-May-2021 02:37:28 KafkaProducerMessageHandlerTests > testOutboundWithAsyncResults() STANDARD_OUT
12-May-2021 02:37:28     2021-05-12 02:37:28,742  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:28     2021-05-12 02:37:28,791  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:28
12-May-2021 02:37:28 KafkaProducerMessageHandlerTests > testOutboundGateway() STANDARD_OUT
12-May-2021 02:37:28     2021-05-12 02:37:28,843  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:28     2021-05-12 02:37:28,950  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:29
12-May-2021 02:37:29 KafkaProducerMessageHandlerTests > testConsumeAndProduceTransactionTxIdOverride() STANDARD_OUT
12-May-2021 02:37:29     2021-05-12 02:37:29,144  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:29     2021-05-12 02:37:29,294  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:29     2021-05-12 02:37:29,445  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:29     2021-05-12 02:37:29,488  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:29     2021-05-12 02:37:29,490  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:29
12-May-2021 02:37:29 KafkaProducerMessageHandlerTests > testOutboundWithTimestamp() STANDARD_OUT
12-May-2021 02:37:29     2021-05-12 02:37:29,536  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:29     2021-05-12 02:37:29,551  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:29
12-May-2021 02:37:29 KafkaProducerMessageHandlerTests > testOutbound() STANDARD_OUT
12-May-2021 02:37:29     2021-05-12 02:37:29,588  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:29     2021-05-12 02:37:29,655  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:29     2021-05-12 02:37:29,792  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:29
12-May-2021 02:37:29 KafkaProducerMessageHandlerTests > testOutboundWithCustomHeaderMapper() STANDARD_OUT
12-May-2021 02:37:29     2021-05-12 02:37:29,802  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:29     2021-05-12 02:37:29,847  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:30
12-May-2021 02:37:30 KafkaProducerMessageHandlerTests STANDARD_OUT
12-May-2021 02:37:30     2021-05-12 02:37:29,995  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,197  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,246  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,389  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,446  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,490  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,490  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,554  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,657  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,692  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,794  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:30     2021-05-12 02:37:30,799  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:30
12-May-2021 02:37:30 KafkaDslKotlinTests STANDARD_OUT
12-May-2021 02:37:30     2021-05-12 02:37:30,956  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:30,971  WARN kafka.server.BrokerMetadataCheckpoint [Test worker] : No meta.properties file under dir /tmp/spring.kafka.45ce251c-2d75-4cf5-ad96-f7050f6f839a5667488420398566035/meta.properties
12-May-2021 02:37:31     2021-05-12 02:37:31,098  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,248  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,344  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,351  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,456  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,545  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,559  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,594  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,649  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,692  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,701  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:31     2021-05-12 02:37:31,958  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:31,998  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,050  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,077  WARN org.springframework.integration.kafka.inbound.KafkaMessageSource [Test worker] : max.poll.records' has been forced from unspecified to 1, to avoid having to seek after each record
12-May-2021 02:37:32     2021-05-12 02:37:32,150  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:32
12-May-2021 02:37:32 KafkaDslKotlinTests > testGateways() STANDARD_OUT
12-May-2021 02:37:32     2021-05-12 02:37:32,249  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,253  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:32
12-May-2021 02:37:32 KafkaDslKotlinTests > testKafkaAdapters() STANDARD_OUT
12-May-2021 02:37:32     2021-05-12 02:37:32,495  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,509  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,511  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,654  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,701  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,702  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,794  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,903  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,952  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:32     2021-05-12 02:37:32,961  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,101  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,102  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,306  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,553  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,563  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,597  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,656  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,662  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,696  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,703  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,953  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:33     2021-05-12 02:37:33,963  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,004  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,056  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,203  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,208  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,508  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,598  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,615  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,655  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,699  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,715  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,805  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:34     2021-05-12 02:37:34,955  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,007  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,105  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,115  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,160  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,258  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,360  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,608  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,659  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,701  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,701  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,717  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,769  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:35     2021-05-12 02:37:35,809  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:35
12-May-2021 02:37:35 KafkaDslKotlinTests STANDARD_OUT
12-May-2021 02:37:35     2021-05-12 02:37:35,958  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,107  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler2] : [Consumer clientId=consumer-replyHandler2-8, groupId=replyHandler2] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,168  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-11] : [Producer clientId=producer-11] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,261  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-6] : [Producer clientId=producer-6] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,310  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-5] : [Producer clientId=producer-5] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,314  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-3] : [Producer clientId=producer-3] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,510  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-9] : [Producer clientId=producer-9] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,603  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler1] : [Consumer clientId=consumer-replyHandler1-12, groupId=replyHandler1] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,710  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-8] : [Producer clientId=producer-8] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,812  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-1] : [Producer clientId=producer-1] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,904  WARN org.apache.kafka.clients.NetworkClient [kafka-coordinator-heartbeat-thread | replyHandler3] : [Consumer clientId=consumer-replyHandler3-14, groupId=replyHandler3] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,920  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-10] : [Producer clientId=producer-10] Connection to node 0 (localhost/127.0.0.1:45819) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,921  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-2] : [Producer clientId=producer-2] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:36     2021-05-12 02:37:36,962  WARN org.apache.kafka.clients.NetworkClient [kafka-producer-network-thread | producer-4] : [Producer clientId=producer-4] Connection to node 0 (localhost/127.0.0.1:35271) could not be established. Broker may not be available.
12-May-2021 02:37:37
12-May-2021 02:37:37 Gradle Test Executor 17 finished executing tests.
12-May-2021 02:37:40
12-May-2021 02:37:40 > Task :spring-integration-kafka:test
12-May-2021 02:37:40 Finished generating test XML results (0.003 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-kafka/build/test-results/test
12-May-2021 02:37:40 Generating HTML test report...
12-May-2021 02:37:40 Finished generating test html results (0.004 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-kafka/build/reports/tests/test
12-May-2021 02:37:40 Stored cache entry for task ':spring-integration-kafka:test' with cache key 7f96eff7dabc7dd88f67f68776cc3420
12-May-2021 02:37:40 :spring-integration-kafka:test (Thread[Execution worker for ':',5,main]) completed. Took 1 mins 18.969 secs.
12-May-2021 02:37:40 :spring-integration-kafka:jacocoTestReport (Thread[Execution worker for ':',5,main]) started.
12-May-2021 02:37:40
12-May-2021 02:37:40 FAILURE: Build failed with an exception.
12-May-2021 02:37:40
12-May-2021 02:37:40 * What went wrong:
12-May-2021 02:37:40 Execution failed for task ':spring-integration-core:test'.
12-May-2021 02:37:40 > There were failing tests. See the report at: file:///opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-core/build/reports/tests/test/index.html
12-May-2021 02:37:40
12-May-2021 02:37:40 * Try:
12-May-2021 02:37:40 Run with --stacktrace option to get the stack trace. Run with --debug option to get more log output. Run with --scan to get full insights.
12-May-2021 02:37:40
12-May-2021 02:37:40 * Get more help at https://help.gradle.org
12-May-2021 02:37:40
12-May-2021 02:37:40 BUILD FAILED in 7m 27s
12-May-2021 02:37:40
12-May-2021 02:37:40 > Task :spring-integration-kafka:jacocoTestReport
12-May-2021 02:37:40 Build cache key for task ':spring-integration-kafka:jacocoTestReport' is 164c8251a6f627de40f49090ae02800a
12-May-2021 02:37:40 Task ':spring-integration-kafka:jacocoTestReport' is not up-to-date because:
12-May-2021 02:37:40   No history is available.
12-May-2021 02:37:40 [ant:jacocoReport] Loading execution data file /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-kafka/build/jacoco.exec
12-May-2021 02:37:40 [ant:jacocoReport] Writing bundle 'spring-integration-kafka' with 48 classes
12-May-2021 02:37:40 Stored cache entry for task ':spring-integration-kafka:jacocoTestReport' with cache key 164c8251a6f627de40f49090ae02800a
12-May-2021 02:37:40 :spring-integration-kafka:jacocoTestReport (Thread[Execution worker for ':',5,main]) completed. Took 0.054 secs.
12-May-2021 02:37:40 Closing Git repo: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/.git
12-May-2021 02:37:40
12-May-2021 02:37:40 Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
12-May-2021 02:37:40 Use '--warning-mode all' to show the individual deprecation warnings.
12-May-2021 02:37:40 See https://docs.gradle.org/6.8.2/userguide/command_line_interface.html#sec:command_line_warnings
12-May-2021 02:37:40 201 actionable tasks: 201 executed
12-May-2021 02:37:41 Failing task since return code of [./gradlew sonarqube --info --no-daemon -Dsonar.projectKey=org.springframework.integration:spring-integration:main -Dsonar.projectName=spring-integration main -Dsonar.host.url=https://sonar.spring.io -Dsonar.login=****** was 1 while expected 0
12-May-2021 02:37:45 SONAR4BAMBOO: was not able to find a SonarQube result URL
12-May-2021 02:37:45 Finished task 'Sonar' with result: Failed
12-May-2021 02:37:45 Running post build plugin 'Docker Container Cleanup'
12-May-2021 02:37:45 Running post build plugin 'NCover Results Collector'
12-May-2021 02:37:45 Running post build plugin 'Artifactory Release Management Staging'
12-May-2021 02:37:45 Running post build plugin 'Artifactory Build Info Copier'
12-May-2021 02:37:45 Running post build plugin 'Artifactory Gradle Properties Info Copier'
12-May-2021 02:37:45 Running post build plugin 'Clover Results Collector'
12-May-2021 02:37:45 Running post build plugin 'npm Cache Cleanup'
12-May-2021 02:37:45 Running post build plugin 'Artifact Copier'
12-May-2021 02:37:45 Publishing an artifact: Test Results
12-May-2021 02:37:45 Finished publishing of artifact Non required job artifact: [Test Results], pattern: [*/build/reports/tests/**/*.*] in 288.2 ms
12-May-2021 02:37:46 Successfully removed working directory at '/opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1'
12-May-2021 02:37:46 Finalising the build...
12-May-2021 02:37:46 Stopping timer.
12-May-2021 02:37:46 Build INT-SONAR-JOB1-3594 completed.
12-May-2021 02:37:44 Running on server: post build plugin 'NCover Results Collector'
12-May-2021 02:37:44 Running on server: post build plugin 'Build Hanging Detection Configuration'
12-May-2021 02:37:44 Running on server: post build plugin 'Bamboo project link creator'
12-May-2021 02:37:44 Running on server: post build plugin 'Clover Delta Calculator'
12-May-2021 02:37:44 Running on server: post build plugin 'Maven Dependencies Postprocessor'
12-May-2021 02:37:44 All post build plugins have finished
12-May-2021 02:37:44 Generating build results summary...
12-May-2021 02:37:44 Saving build results to disk...
12-May-2021 02:37:44 Logging substituted variables...
12-May-2021 02:37:44 Indexing build results...
12-May-2021 02:37:44 Finished building INT-SONAR-JOB1-3594.