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

Build: #3595 failed

Job: Default Job failed

Stages & jobs

  1. Default Stage

Build log

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

13-May-2021 02:40:17 :spring-integration-r2dbc:compileJava (Thread[Execution worker for ':' Thread 2,5,main]) completed. Took 0.63 secs.
13-May-2021 02:40:17 :spring-integration-r2dbc:classes (Thread[Execution worker for ':' Thread 2,5,main]) started.
13-May-2021 02:40:17
13-May-2021 02:40:17 > Task :spring-integration-r2dbc:classes
13-May-2021 02:40:17 Skipping task ':spring-integration-r2dbc:classes' as it has no actions.
13-May-2021 02:40:17 :spring-integration-r2dbc:classes (Thread[Execution worker for ':' Thread 2,5,main]) completed. Took 0.0 secs.
13-May-2021 02:40:17 :spring-integration-r2dbc:compileTestKotlin (Thread[Execution worker for ':' Thread 2,5,main]) started.
13-May-2021 02:40:17
13-May-2021 02:40:17 > Task :spring-integration-r2dbc:compileTestKotlin
13-May-2021 02:40:17 file or directory '/opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-r2dbc/src/test/kotlin', not found
13-May-2021 02:40:17 Downloading https://repo.maven.apache.org/maven2/io/r2dbc/r2dbc-h2/0.8.4.RELEASE/r2dbc-h2-0.8.4.RELEASE.pom to /tmp/gradle_download11174070897573733229bin
13-May-2021 02:40:17 Downloading https://repo.maven.apache.org/maven2/io/r2dbc/r2dbc-h2/0.8.4.RELEASE/r2dbc-h2-0.8.4.RELEASE.jar to /tmp/gradle_download15782144008056344652bin
13-May-2021 02:40:17 Build cache key for task ':spring-integration-r2dbc:compileTestKotlin' is 570573027fe811e9d70b72a35f98cb95
13-May-2021 02:40:17 Task ':spring-integration-r2dbc:compileTestKotlin' is not up-to-date because:
13-May-2021 02:40:17   No history is available.
13-May-2021 02:40:17 The input changes require a full rebuild for incremental task ':spring-integration-r2dbc:compileTestKotlin'.
13-May-2021 02:40:17 file or directory '/opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-r2dbc/src/test/kotlin', not found
13-May-2021 02:40:17 file or directory '/opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-r2dbc/src/test/kotlin', not found
13-May-2021 02:40:17 file or directory '/opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-r2dbc/src/test/kotlin', not found
13-May-2021 02:40:17 file or directory '/opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-r2dbc/src/test/kotlin', not found
13-May-2021 02:40:17 Stored cache entry for task ':spring-integration-r2dbc:compileTestKotlin' with cache key 570573027fe811e9d70b72a35f98cb95
13-May-2021 02:40:17 :spring-integration-r2dbc:compileTestKotlin (Thread[Execution worker for ':' Thread 2,5,main]) completed. Took 0.532 secs.
13-May-2021 02:40:17 :spring-integration-r2dbc:compileTestJava (Thread[Execution worker for ':' Thread 2,5,main]) started.
13-May-2021 02:40:17
13-May-2021 02:40:17 > Task :spring-integration-kafka:test
13-May-2021 02:40:17     2021-05-13 02:40:16,077  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,078  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,345  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,346  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,346  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,347  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,546  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,747  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,747  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,897  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,947  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,948  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:16,998  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:17,048  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:17,149  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:17,360  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:17,360  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:17,361  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17
13-May-2021 02:40:17 KafkaDslTests > testKafkaAdapters() STANDARD_OUT
13-May-2021 02:40:17     2021-05-13 02:40:17,461  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:17,661  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:17,662  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:17     2021-05-13 02:40:17,709  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:17,762  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:17,965  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:17,966  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,066  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,167  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,266  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,316  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,317  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,319  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,576 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
13-May-2021 02:40:18     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[email protected], correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:18             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
13-May-2021 02:40:18             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
13-May-2021 02:40:18             at java.lang.Thread.run(Thread.java:829) [?:?]
13-May-2021 02:40:18     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             ... 9 more
13-May-2021 02:40:18     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'
13-May-2021 02:40:18             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
13-May-2021 02:40:18             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
13-May-2021 02:40:18             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
13-May-2021 02:40:18             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             ... 9 more
13-May-2021 02:40:18     2021-05-13 02:40:18,583  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,676  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,681  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:18     2021-05-13 02:40:18,690 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
13-May-2021 02:40:18     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:18             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
13-May-2021 02:40:18             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
13-May-2021 02:40:18             at java.lang.Thread.run(Thread.java:829) [?:?]
13-May-2021 02:40:18     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             ... 9 more
13-May-2021 02:40:18     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'
13-May-2021 02:40:18             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
13-May-2021 02:40:18             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
13-May-2021 02:40:18             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
13-May-2021 02:40:18             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:18             ... 9 more
13-May-2021 02:40:18     2021-05-13 02:40:18,726  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:18
13-May-2021 02:40:18 > Task :spring-integration-r2dbc:compileTestJava
13-May-2021 02:40:18 Custom actions are attached to task ':spring-integration-r2dbc:compileTestJava'.
13-May-2021 02:40:18 Build cache key for task ':spring-integration-r2dbc:compileTestJava' is 5f07c60589a7963df7360a8adef0047d
13-May-2021 02:40:18 Task ':spring-integration-r2dbc:compileTestJava' is not up-to-date because:
13-May-2021 02:40:18   No history is available.
13-May-2021 02:40:18 The input changes require a full rebuild for incremental task ':spring-integration-r2dbc:compileTestJava'.
13-May-2021 02:40:18 Full recompilation is required because no incremental change information is available. This is usually caused by clean builds or changing compiler arguments.
13-May-2021 02:40:18 Compiling with JDK Java compiler API.
13-May-2021 02:40:18 Created classpath snapshot for incremental compilation in 0.034 secs. 1 duplicate classes found in classpath (see all with --debug).
13-May-2021 02:40:18 Stored cache entry for task ':spring-integration-r2dbc:compileTestJava' with cache key 5f07c60589a7963df7360a8adef0047d
13-May-2021 02:40:18 :spring-integration-r2dbc:compileTestJava (Thread[Execution worker for ':' Thread 2,5,main]) completed. Took 1.165 secs.
13-May-2021 02:40:18 :spring-integration-r2dbc:testClasses (Thread[Execution worker for ':' Thread 2,5,main]) started.
13-May-2021 02:40:18
13-May-2021 02:40:18 > Task :spring-integration-r2dbc:testClasses
13-May-2021 02:40:18 Skipping task ':spring-integration-r2dbc:testClasses' as it has no actions.
13-May-2021 02:40:18 :spring-integration-r2dbc:testClasses (Thread[Execution worker for ':' Thread 2,5,main]) completed. Took 0.0 secs.
13-May-2021 02:40:18 :spring-integration-r2dbc:test (Thread[Execution worker for ':' Thread 2,5,main]) started.
13-May-2021 02:40:20
13-May-2021 02:40:20 > Task :spring-integration-kafka:test
13-May-2021 02:40:20     2021-05-13 02:40:18,797 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
13-May-2021 02:40:20             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
13-May-2021 02:40:20             at java.lang.Thread.run(Thread.java:829) [?:?]
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     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'
13-May-2021 02:40:20             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     2021-05-13 02:40:18,914 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
13-May-2021 02:40:20             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
13-May-2021 02:40:20             at java.lang.Thread.run(Thread.java:829) [?:?]
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     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'
13-May-2021 02:40:20             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     2021-05-13 02:40:18,927  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:18,976  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:18,978  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:18,981  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,094 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
13-May-2021 02:40:20             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
13-May-2021 02:40:20             at java.lang.Thread.run(Thread.java:829) [?:?]
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     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'
13-May-2021 02:40:20             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     2021-05-13 02:40:19,144  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,144  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,145  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,204 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
13-May-2021 02:40:20             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
13-May-2021 02:40:20             at java.lang.Thread.run(Thread.java:829) [?:?]
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     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'
13-May-2021 02:40:20             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     2021-05-13 02:40:19,294  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,317 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
13-May-2021 02:40:20     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_consu[email protected], correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
13-May-2021 02:40:20             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
13-May-2021 02:40:20             at java.lang.Thread.run(Thread.java:829) [?:?]
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     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'
13-May-2021 02:40:20             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20
13-May-2021 02:40:20 KafkaDslTests STANDARD_OUT
13-May-2021 02:40:20     2021-05-13 02:40:19,424 ERROR org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer [topic2ListenerFromKafkaFlow.org.springframework.kafka.listener.ConcurrentMessageListenerContainer#0-0-C-1] : Error handler threw an exception
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:206) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:112) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:2355) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2224) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2138) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2020) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1702) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1272) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1264) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1161) [spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
13-May-2021 02:40:20             at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
13-May-2021 02:40:20             at java.lang.Thread.run(Thread.java:829) [?:?]
13-May-2021 02:40:20     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]ca8e120, correlationId=0ce36622-a619-d7d7-995b-366e0f4cf467, 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, 48, 99, 101, 51, 54, 54, 50, 50, 45, 97, 54, 49, 57, 45, 100, 55, 100, 55, 45, 57, 57, 53, 98, 45, 51, 54, 54, 101, 48, 102, 52, 99, 102, 52, 54, 55, 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}]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2370) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2338) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     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'
13-May-2021 02:40:20             at org.springframework.integration.filter.MessageFilter.postProcess(MessageFilter.java:187) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingPostProcessingMessageHandler.handleRequestMessage(AbstractReplyProducingPostProcessingMessageHandler.java:52) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:56) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.AbstractDispatcher.tryOptimizedDispatch(AbstractDispatcher.java:115) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:133) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:106) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:72) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:317) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:272) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:187) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:166) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.GenericMessagingTemplate.doSend(GenericMessagingTemplate.java:47) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.messaging.core.AbstractMessageSendingTemplate.send(AbstractMessageSendingTemplate.java:109) ~[spring-messaging-5.3.7-SNAPSHOT.jar:5.3.7-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.endpoint.MessageProducerSupport.sendMessage(MessageProducerSupport.java:208) ~[spring-integration-core-5.5.0-SNAPSHOT.jar:5.5.0-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.sendMessageIfAny(KafkaMessageDrivenChannelAdapter.java:397) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter.access$300(KafkaMessageDrivenChannelAdapter.java:79) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:456) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter$IntegrationRecordMessageListener.onMessage(KafkaMessageDrivenChannelAdapter.java:430) ~[main/:?]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2318) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2299) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2213) ~[spring-kafka-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:20             ... 9 more
13-May-2021 02:40:20     2021-05-13 02:40:19,447  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,785  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,786  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,836  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,885  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,886  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,986  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:19,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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:20,187  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:20,188  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:20,356  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:20,356  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:20,356  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:20,456  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:20     2021-05-13 02:40:20,607  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:20,931  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:20,931  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:20,931  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:21,032  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:21,083  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:21,133  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:21,133  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:21,233  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:21,332  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:21,383  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:21,383  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:21     2021-05-13 02:40:21,570  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:21
13-May-2021 02:40:21 Gradle Test Executor 20 started executing tests.
13-May-2021 02:40:21
13-May-2021 02:40:21 > Task :spring-integration-r2dbc:test
13-May-2021 02:40:21 Custom actions are attached to task ':spring-integration-r2dbc:test'.
13-May-2021 02:40:21 Build cache key for task ':spring-integration-r2dbc:test' is dd1290ac83d01c564b34223ae9ab6bbc
13-May-2021 02:40:21 Task ':spring-integration-r2dbc:test' is not up-to-date because:
13-May-2021 02:40:21   No history is available.
13-May-2021 02:40:21 Starting process 'Gradle Test Executor 20'. Working directory: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-r2dbc Command: /opt/jdk-11.0.11+9/bin/java -Dorg.gradle.native=false -XX:+HeapDumpOnOutOfMemoryError -javaagent:build/tmp/expandedArchives/org.jacoco.agent-0.8.6.jar_a26f6511a7813217be4cd6439d66563b/jacocoagent.jar=destfile=build/jacoco.exec,append=true,inclnolocationclasses=false,dumponexit=true,output=file,jmx=false @/tmp/gradle-worker-classpath1179090568272845126txt -Xmx2g -Dfile.encoding=UTF-8 -Duser.country=US -Duser.language=en -Duser.variant worker.org.gradle.process.internal.worker.GradleWorkerMain 'Gradle Test Executor 20'
13-May-2021 02:40:21 Successfully started process 'Gradle Test Executor 20'
13-May-2021 02:40:31
13-May-2021 02:40:31 > Task :spring-integration-core:test FAILED
13-May-2021 02:40:31
13-May-2021 02:40:31 2216 tests completed, 1 failed, 19 skipped
13-May-2021 02:40:31 Finished generating test XML results (0.037 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-core/build/test-results/test
13-May-2021 02:40:31 Generating HTML test report...
13-May-2021 02:40:31 Finished generating test html results (0.121 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-core/build/reports/tests/test
13-May-2021 02:40:31 :spring-integration-core:test (Thread[Daemon worker,5,main]) completed. Took 6 mins 46.15 secs.
13-May-2021 02:40:31 :spring-integration-core:jacocoTestReport (Thread[Daemon worker,5,main]) started.
13-May-2021 02:40:31
13-May-2021 02:40:31 > Task :spring-integration-kafka:test
13-May-2021 02:40:31     2021-05-13 02:40:21,721  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:21,875  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:21,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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:21,912  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,076  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,076  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,077  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,126  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,272  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,423  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,473  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,473  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,705  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,855  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,956  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:22,977  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,006  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,167  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,268  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,319  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,418  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,469  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,569  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,698  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 ChannelTests STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:23,749  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,848  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:23,911  WARN kafka.server.BrokerMetadataCheckpoint [Test worker] : No meta.properties file under dir /tmp/spring.kafka.f27a1625-37e5-4d47-9fcb-041be570c07f6927636360888705860/meta.properties
13-May-2021 02:40:31     2021-05-13 02:40:24,125  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,126  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,126  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,175  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,178  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,229  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,326  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,327  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,480  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,807  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,807  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,935  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:24,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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,036  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,036  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,066  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
13-May-2021 02:40:31     2021-05-13 02:40:25,086  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,086  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,087  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 ChannelTests > pubSub(SubscribableChannel) STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:25,245  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 ChannelTests > pollable(PollableChannel) STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:25,455  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,455  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:25,649  WARN kafka.server.BrokerMetadataCheckpoint [Test worker] : No meta.properties file under dir /tmp/spring.kafka.25e1b53f-40b4-4615-bc42-a18e0a8ff2c08372763539631992893/meta.properties
13-May-2021 02:40:31     2021-05-13 02:40:25,785  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,816  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,816  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,835  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:25,917  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,016  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,117  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,137  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,187  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,188  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,205  WARN org.apache.kafka.common.utils.AppInfoParser [Test worker] : Error registering AppInfo mbean
13-May-2021 02:40:31     javax.management.InstanceAlreadyExistsException: kafka.server:type=app-info,id=0
13-May-2021 02:40:31             at com.sun.jmx.mbeanserver.Repository.addMBean(Repository.java:436) ~[?:?]
13-May-2021 02:40:31             at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerWithRepository(DefaultMBeanServerInterceptor.java:1855) ~[?:?]
13-May-2021 02:40:31             at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerDynamicMBean(DefaultMBeanServerInterceptor.java:955) ~[?:?]
13-May-2021 02:40:31             at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerObject(DefaultMBeanServerInterceptor.java:890) ~[?:?]
13-May-2021 02:40:31             at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.registerMBean(DefaultMBeanServerInterceptor.java:320) ~[?:?]
13-May-2021 02:40:31             at com.sun.jmx.mbeanserver.JmxMBeanServer.registerMBean(JmxMBeanServer.java:522) ~[?:?]
13-May-2021 02:40:31             at org.apache.kafka.common.utils.AppInfoParser.registerAppInfo(AppInfoParser.java:64) ~[kafka-clients-2.7.0.jar:?]
13-May-2021 02:40:31             at kafka.server.KafkaServer.startup(KafkaServer.scala:393) ~[kafka_2.13-2.7.0.jar:?]
13-May-2021 02:40:31             at kafka.utils.TestUtils$.createServer(TestUtils.scala:161) ~[kafka_2.13-2.7.0-test.jar:?]
13-May-2021 02:40:31             at kafka.utils.TestUtils$.createServer(TestUtils.scala:152) ~[kafka_2.13-2.7.0-test.jar:?]
13-May-2021 02:40:31             at kafka.utils.TestUtils.createServer(TestUtils.scala) ~[kafka_2.13-2.7.0-test.jar:?]
13-May-2021 02:40:31             at org.springframework.kafka.test.EmbeddedKafkaBroker.afterPropertiesSet(EmbeddedKafkaBroker.java:337) ~[spring-kafka-test-2.7.1-SNAPSHOT.jar:2.7.1-SNAPSHOT]
13-May-2021 02:40:31             at org.springframework.integration.kafka.outbound.KafkaProducerMessageHandlerTests.setup(KafkaProducerMessageHandlerTests.java:136) ~[test/:?]
13-May-2021 02:40:31             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
13-May-2021 02:40:31             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
13-May-2021 02:40:31             at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
13-May-2021 02:40:31             at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
13-May-2021 02:40:31             at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688) ~[junit-platform-commons-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.extension.TimeoutExtension.interceptLifecycleMethod(TimeoutExtension.java:126) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.extension.TimeoutExtension.interceptBeforeAllMethod(TimeoutExtension.java:68) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.lambda$invokeBeforeAllMethods$9(ClassBasedTestDescriptor.java:384) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.invokeBeforeAllMethods(ClassBasedTestDescriptor.java:382) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.before(ClassBasedTestDescriptor.java:196) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.jupiter.engine.descriptor.ClassBasedTestDescriptor.before(ClassBasedTestDescriptor.java:78) ~[junit-jupiter-engine-5.7.1.jar:5.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:136) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at java.util.ArrayList.forEach(ArrayList.java:1541) ~[?:?]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51) ~[junit-platform-engine-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:108) ~[junit-platform-launcher-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88) ~[junit-platform-launcher-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54) ~[junit-platform-launcher-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67) [junit-platform-launcher-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52) [junit-platform-launcher-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:96) [junit-platform-launcher-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:75) [junit-platform-launcher-1.7.1.jar:1.7.1]
13-May-2021 02:40:31             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]
13-May-2021 02:40:31             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]
13-May-2021 02:40:31             at org.gradle.api.internal.tasks.testing.junitplatform.JUnitPlatformTestClassProcessor.stop(JUnitPlatformTestClassProcessor.java:75) [gradle-testing-junit-platform-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.stop(SuiteTestClassProcessor.java:61) [gradle-testing-base-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
13-May-2021 02:40:31             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
13-May-2021 02:40:31             at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
13-May-2021 02:40:31             at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
13-May-2021 02:40:31             at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36) [gradle-messaging-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24) [gradle-messaging-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:33) [gradle-messaging-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:94) [gradle-messaging-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at com.sun.proxy.$Proxy5.stop(Unknown Source) [?:?]
13-May-2021 02:40:31             at org.gradle.api.internal.tasks.testing.worker.TestWorker.stop(TestWorker.java:133) [gradle-testing-base-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
13-May-2021 02:40:31             at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:?]
13-May-2021 02:40:31             at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
13-May-2021 02:40:31             at java.lang.reflect.Method.invoke(Method.java:566) ~[?:?]
13-May-2021 02:40:31             at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:36) [gradle-messaging-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24) [gradle-messaging-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:182) [gradle-messaging-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.internal.remote.internal.hub.MessageHubBackedObjectConnection$DispatchWrapper.dispatch(MessageHubBackedObjectConnection.java:164) [gradle-messaging-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:414) [gradle-messaging-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:64) [gradle-base-services-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at org.gradle.internal.concurrent.ManagedExecutorImpl$1.run(ManagedExecutorImpl.java:48) [gradle-base-services-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
13-May-2021 02:40:31             at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
13-May-2021 02:40:31             at org.gradle.internal.concurrent.ThreadFactoryImpl$ManagedThreadRunnable.run(ThreadFactoryImpl.java:56) [gradle-base-services-6.8.2.jar:6.8.2]
13-May-2021 02:40:31             at java.lang.Thread.run(Thread.java:829) [?:?]
13-May-2021 02:40:31     2021-05-13 02:40:26,218  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,795  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,796  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,796  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,797  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,846  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,946  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,996  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:26,996  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:27,122  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:27,173  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests > testConsumeAndProduceTransaction() STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:27,277  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:27,323  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:27,377  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:27,799  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:27,899  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:27,899  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:27,908  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests > testOutboundGatewayPrPayload() STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:27,950  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:27,999  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,049  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,100  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,151  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests > testFlush() STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:28,415  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,416  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,416  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,416  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests > testOutboundWithAsyncResults() STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:28,956  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,957  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,957  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,957  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:28,958  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:29,008  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests > testOutboundGateway() STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:29,057  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:29,058  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:29,436  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:29,438  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:29,439  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:29,439  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:29,487  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests > testConsumeAndProduceTransactionTxIdOverride() STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:29,837  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,045  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,046  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,046  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,045  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,047  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,047  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests > testOutboundWithTimestamp() STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:30,054  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests > testOutbound() STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:30,246  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,399  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests > testOutboundWithCustomHeaderMapper() STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:30,656  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,656  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,656  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31
13-May-2021 02:40:31 KafkaProducerMessageHandlerTests STANDARD_OUT
13-May-2021 02:40:31     2021-05-13 02:40:30,906  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:30,957  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,110  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,355  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,356  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,356  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,356  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,510  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,510  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,711  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,757  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,857  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,861  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:31     2021-05-13 02:40:31,908  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:32     2021-05-13 02:40:31,957  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:32     2021-05-13 02:40:32,166  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:32     2021-05-13 02:40:32,366  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:32     2021-05-13 02:40:32,366  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:32
13-May-2021 02:40:32 > Task :spring-integration-core:jacocoTestReport
13-May-2021 02:40:32 Build cache key for task ':spring-integration-core:jacocoTestReport' is 390cecfe1df6330b72d2cb122bf9ac12
13-May-2021 02:40:32 Task ':spring-integration-core:jacocoTestReport' is not up-to-date because:
13-May-2021 02:40:32   No history is available.
13-May-2021 02:40:32 [ant:jacocoReport] Loading execution data file /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-core/build/jacoco.exec
13-May-2021 02:40:32 [ant:jacocoReport] Writing bundle 'spring-integration-core' with 801 classes
13-May-2021 02:40:32 Stored cache entry for task ':spring-integration-core:jacocoTestReport' with cache key 390cecfe1df6330b72d2cb122bf9ac12
13-May-2021 02:40:32 :spring-integration-core:jacocoTestReport (Thread[Daemon worker,5,main]) completed. Took 1.02 secs.
13-May-2021 02:40:33 Gradle Test Executor 20 finished executing tests.
13-May-2021 02:40:33
13-May-2021 02:40:33 > Task :spring-integration-r2dbc:test
13-May-2021 02:40:33 Finished generating test XML results (0.0 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-r2dbc/build/test-results/test
13-May-2021 02:40:33 Generating HTML test report...
13-May-2021 02:40:33 Finished generating test html results (0.001 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-r2dbc/build/reports/tests/test
13-May-2021 02:40:33 Stored cache entry for task ':spring-integration-r2dbc:test' with cache key dd1290ac83d01c564b34223ae9ab6bbc
13-May-2021 02:40:33 :spring-integration-r2dbc:test (Thread[Execution worker for ':' Thread 2,5,main]) completed. Took 14.92 secs.
13-May-2021 02:40:33 :spring-integration-r2dbc:jacocoTestReport (Thread[Execution worker for ':' Thread 2,5,main]) started.
13-May-2021 02:40:33
13-May-2021 02:40:33 > Task :spring-integration-r2dbc:jacocoTestReport
13-May-2021 02:40:33 Build cache key for task ':spring-integration-r2dbc:jacocoTestReport' is 33364372782843fa54ddb21174088e13
13-May-2021 02:40:33 Task ':spring-integration-r2dbc:jacocoTestReport' is not up-to-date because:
13-May-2021 02:40:33   No history is available.
13-May-2021 02:40:33 [ant:jacocoReport] Loading execution data file /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-r2dbc/build/jacoco.exec
13-May-2021 02:40:33 [ant:jacocoReport] Writing bundle 'spring-integration-r2dbc' with 7 classes
13-May-2021 02:40:33 Stored cache entry for task ':spring-integration-r2dbc:jacocoTestReport' with cache key 33364372782843fa54ddb21174088e13
13-May-2021 02:40:33 :spring-integration-r2dbc:jacocoTestReport (Thread[Execution worker for ':' Thread 2,5,main]) completed. Took 0.026 secs.
13-May-2021 02:40:34
13-May-2021 02:40:34 > Task :spring-integration-kafka:test
13-May-2021 02:40:34     2021-05-13 02:40:32,416  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:32,466  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:32,467  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:32,566  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:32,667  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:32,667  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:32,717  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:32,867  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,105  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,116  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,166  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,316  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,416  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,416  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,517  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,556  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,606  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,618  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,717  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,917  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:33,918  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,007  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,119  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,318  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,319  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,469  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,508  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,517  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,519  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,617  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,659  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,768  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,820  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:34     2021-05-13 02:40:34,820  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,109  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:35
13-May-2021 02:40:35 KafkaDslKotlinTests STANDARD_OUT
13-May-2021 02:40:35     2021-05-13 02:40:35,220  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,225  WARN kafka.server.BrokerMetadataCheckpoint [Test worker] : No meta.properties file under dir /tmp/spring.kafka.d1af8502-e9b2-43d6-beb4-ec6056aa231318182531033145770751/meta.properties
13-May-2021 02:40:35     2021-05-13 02:40:35,271  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,321  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,410  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,419  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,472  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,621  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,720  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,723  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,812  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:35     2021-05-13 02:40:35,819  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,022  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,221  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,223  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,223  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,311  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,324  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,343  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
13-May-2021 02:40:36     2021-05-13 02:40:36,421  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:36
13-May-2021 02:40:36 KafkaDslKotlinTests > testGateways() STANDARD_OUT
13-May-2021 02:40:36     2021-05-13 02:40:36,472  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:36
13-May-2021 02:40:36 KafkaDslKotlinTests > testKafkaAdapters() STANDARD_OUT
13-May-2021 02:40:36     2021-05-13 02:40:36,572  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,613  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,673  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,715  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:36     2021-05-13 02:40:36,728  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:36,974  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,123  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,223  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,324  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,325  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,375  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,427  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,474  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,514  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,614  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,775  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:37     2021-05-13 02:40:37,918  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:37,930  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,027  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,125  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,225  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,227  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,326  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,415  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,527  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,529  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,577  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,716  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:38     2021-05-13 02:40:38,820  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:38,927  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:38,977  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,082  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,226  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,317  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,327  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,377  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,378  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,432  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,478  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,529  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,622  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:39     2021-05-13 02:40:39,818  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:39,929  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:39,979  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,083  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:40
13-May-2021 02:40:40 KafkaDslKotlinTests STANDARD_OUT
13-May-2021 02:40:40     2021-05-13 02:40:40,228  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,280  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,319  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,330  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,384  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,429  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,531  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,630  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,675  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,819  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:40     2021-05-13 02:40:40,831  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:41     2021-05-13 02:40:41,081  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:45775) could not be established. Broker may not be available.
13-May-2021 02:40:41     2021-05-13 02:40:41,184  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:41     2021-05-13 02:40:41,229  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:41709) could not be established. Broker may not be available.
13-May-2021 02:40:41
13-May-2021 02:40:41 Gradle Test Executor 17 finished executing tests.
13-May-2021 02:40:44
13-May-2021 02:40:44 > Task :spring-integration-kafka:test
13-May-2021 02:40:44 Finished generating test XML results (0.005 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-kafka/build/test-results/test
13-May-2021 02:40:44 Generating HTML test report...
13-May-2021 02:40:44 Finished generating test html results (0.009 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-kafka/build/reports/tests/test
13-May-2021 02:40:44 Stored cache entry for task ':spring-integration-kafka:test' with cache key 56b57af413e93201c017ec24b635ef61
13-May-2021 02:40:44 :spring-integration-kafka:test (Thread[Execution worker for ':',5,main]) completed. Took 1 mins 39.258 secs.
13-May-2021 02:40:44 :spring-integration-kafka:jacocoTestReport (Thread[Daemon worker,5,main]) started.
13-May-2021 02:40:44
13-May-2021 02:40:44 > Task :spring-integration-kafka:jacocoTestReport
13-May-2021 02:40:44 Build cache key for task ':spring-integration-kafka:jacocoTestReport' is 84306c288ab51b69ab10b92cd28937ef
13-May-2021 02:40:44 Task ':spring-integration-kafka:jacocoTestReport' is not up-to-date because:
13-May-2021 02:40:44   No history is available.
13-May-2021 02:40:44 [ant:jacocoReport] Loading execution data file /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-kafka/build/jacoco.exec
13-May-2021 02:40:44 [ant:jacocoReport] Writing bundle 'spring-integration-kafka' with 48 classes
13-May-2021 02:40:44 Stored cache entry for task ':spring-integration-kafka:jacocoTestReport' with cache key 84306c288ab51b69ab10b92cd28937ef
13-May-2021 02:40:44 :spring-integration-kafka:jacocoTestReport (Thread[Daemon worker,5,main]) completed. Took 0.051 secs.
13-May-2021 02:41:02
13-May-2021 02:41:02 > Task :spring-integration-mqtt:test
13-May-2021 02:41:02
13-May-2021 02:41:02 DownstreamExceptionTests > testNoErrorChannel STANDARD_OUT
13-May-2021 02:41:02     2021-05-13 02:41:02,449 ERROR [MQTT Call: fooEx1] [org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter] - Lost connection: MqttException; retrying...
13-May-2021 02:41:07
13-May-2021 02:41:07 Gradle Test Executor 19 finished executing tests.
13-May-2021 02:41:07
13-May-2021 02:41:07 > Task :spring-integration-mqtt:test
13-May-2021 02:41:07 Finished generating test XML results (0.001 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-mqtt/build/test-results/test
13-May-2021 02:41:07 Generating HTML test report...
13-May-2021 02:41:07 Finished generating test html results (0.002 secs) into: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-mqtt/build/reports/tests/test
13-May-2021 02:41:07 Stored cache entry for task ':spring-integration-mqtt:test' with cache key 86612bcd5aeb6bb30fdb6a77e96d5a0d
13-May-2021 02:41:07 :spring-integration-mqtt:test (Thread[Execution worker for ':' Thread 3,5,main]) completed. Took 1 mins 30.247 secs.
13-May-2021 02:41:07 :spring-integration-mqtt:jacocoTestReport (Thread[Execution worker for ':' Thread 3,5,main]) started.
13-May-2021 02:41:07
13-May-2021 02:41:07 FAILURE: Build failed with an exception.
13-May-2021 02:41:07
13-May-2021 02:41:07
13-May-2021 02:41:07 > Task :spring-integration-mqtt:jacocoTestReport
13-May-2021 02:41:07 * What went wrong:
13-May-2021 02:41:07 Build cache key for task ':spring-integration-mqtt:jacocoTestReport' is c05cd23a48b22aa7d8bbac1876e8666c
13-May-2021 02:41:07 Execution failed for task ':spring-integration-core:test'.
13-May-2021 02:41:07 Task ':spring-integration-mqtt:jacocoTestReport' is not up-to-date because:
13-May-2021 02:41:07 > 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
13-May-2021 02:41:07   No history is available.
13-May-2021 02:41:07
13-May-2021 02:41:07 [ant:jacocoReport] Loading execution data file /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/spring-integration-mqtt/build/jacoco.exec
13-May-2021 02:41:07 * Try:
13-May-2021 02:41:07 [ant:jacocoReport] Writing bundle 'spring-integration-mqtt' with 24 classes
13-May-2021 02:41:07 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.
13-May-2021 02:41:07 Stored cache entry for task ':spring-integration-mqtt:jacocoTestReport' with cache key c05cd23a48b22aa7d8bbac1876e8666c
13-May-2021 02:41:07
13-May-2021 02:41:07 :spring-integration-mqtt:jacocoTestReport (Thread[Execution worker for ':' Thread 3,5,main]) completed. Took 0.038 secs.
13-May-2021 02:41:07 * Get more help at https://help.gradle.org
13-May-2021 02:41:07 Closing Git repo: /opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1/.git
13-May-2021 02:41:07
13-May-2021 02:41:07
13-May-2021 02:41:07 BUILD FAILED in 10m 48s
13-May-2021 02:41:07 Deprecated Gradle features were used in this build, making it incompatible with Gradle 7.0.
13-May-2021 02:41:07 Use '--warning-mode all' to show the individual deprecation warnings.
13-May-2021 02:41:07 See https://docs.gradle.org/6.8.2/userguide/command_line_interface.html#sec:command_line_warnings
13-May-2021 02:41:07 221 actionable tasks: 221 executed
13-May-2021 02:41:08 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
13-May-2021 02:41:13 SONAR4BAMBOO: was not able to find a SonarQube result URL
13-May-2021 02:41:13 Finished task 'Sonar' with result: Failed
13-May-2021 02:41:13 Running post build plugin 'Docker Container Cleanup'
13-May-2021 02:41:13 Running post build plugin 'NCover Results Collector'
13-May-2021 02:41:13 Running post build plugin 'Artifactory Release Management Staging'
13-May-2021 02:41:13 Running post build plugin 'Artifactory Build Info Copier'
13-May-2021 02:41:13 Running post build plugin 'Artifactory Gradle Properties Info Copier'
13-May-2021 02:41:13 Running post build plugin 'Clover Results Collector'
13-May-2021 02:41:13 Running post build plugin 'npm Cache Cleanup'
13-May-2021 02:41:13 Running post build plugin 'Artifact Copier'
13-May-2021 02:41:13 Publishing an artifact: Test Results
13-May-2021 02:41:13 Finished publishing of artifact Non required job artifact: [Test Results], pattern: [*/build/reports/tests/**/*.*] in 305.4 ms
13-May-2021 02:41:13 Successfully removed working directory at '/opt/bamboo-home/xml-data/build-dir/INT-SONAR-JOB1'
13-May-2021 02:41:13 Finalising the build...
13-May-2021 02:41:13 Stopping timer.
13-May-2021 02:41:13 Build INT-SONAR-JOB1-3595 completed.
13-May-2021 02:41:13 Running on server: post build plugin 'NCover Results Collector'
13-May-2021 02:41:13 Running on server: post build plugin 'Build Hanging Detection Configuration'
13-May-2021 02:41:13 Running on server: post build plugin 'Bamboo project link creator'
13-May-2021 02:41:13 Running on server: post build plugin 'Clover Delta Calculator'
13-May-2021 02:41:13 Running on server: post build plugin 'Maven Dependencies Postprocessor'
13-May-2021 02:41:13 All post build plugins have finished
13-May-2021 02:41:13 Generating build results summary...
13-May-2021 02:41:13 Saving build results to disk...
13-May-2021 02:41:13 Logging substituted variables...
13-May-2021 02:41:13 Indexing build results...
13-May-2021 02:41:13 Finished building INT-SONAR-JOB1-3595.