java.lang.AssertionError: GOT A TIMEOUT: While expecting the consume of 'String'. Messages so far: Consumed: ?[33mList?[39m( ?[33mConsumed?[39m( topic = ?[32m"topic"?[39m, value = ?[33mByteArray?[39m(), metadata = ?[33mMessageMetadata?[39m( topic = ?[32m"topic"?[39m, key = ?[32m"null"?[39m, headers = ?[33mMap?[39m(?[32m"x-user-id"?[39m -> ?[32m"1486549027"?[39m) ), partition = ?[32m0?[39m, key = ?[32m""?[39m, timestamp = ?[32m1765293194590L?[39m, offset = ?[32m0L?[39m, valueAsString = ?[32m"\"this message is coming from publish and consume and testName is publish and consume\""?[39m ), ?[33mConsumed?[39m( topic = ?[32m"topic-failed-dlt"?[39m, value = ?[33mByteArray?[39m(), metadata = ?[33mMessageMetadata?[39m( topic = ?[32m"topic-failed-dlt"?[39m, key = ?[32m"null"?[39m, headers = ?[33mMap?[39m( ?[32m"x-user-id"?[39m -> ?[32m"-1909654526"?[39m, ?[32m"kafka_dlt-exception-fqcn"?[39m -> ?[32m"org.springframework.kafka.listener.ListenerExecutionFailedException"?[39m, ?[32m"kafka_dlt-exception-cause-fqcn"?[39m -> ?[32m"com.trendyol.stove.testing.e2e.kafka.StoveBusinessException"?[39m, ?[32m"kafka_dlt-exception-message"?[39m -> ?[32m"Listener method \'public final void com.trendyol.stove.testing.e2e.kafka.stringserde.KafkaTestSpringBotApplicationForStringSerde.listenFailed(java.lang.String)\' threw exception; This exception is thrown intentionally for testing purposes."?[39m, ?[32m"kafka_dlt-exception-stacktrace"?[39m -> ?[32m"""org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public final void com.trendyol.stove.testing.e2e.kafka.stringserde.KafkaTestSpringBotApplicationForStringSerde.listenFailed(java.lang.String)' threw exception at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2994) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2901) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2865) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2777) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2614) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2503) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2152) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1528) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1466) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1335) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) at java.base/java.lang.Thread.run(Thread.java:840) Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2887) Caused by: com.trendyol.stove.testing.e2e.kafka.StoveBusinessException: This exception is thrown intentionally for testing purposes. at com.trendyol.stove.testing.e2e.kafka.stringserde.KafkaTestSpringBotApplicationForStringSerde.listenFailed(app.kt:106) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:569) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169) at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2887) ... 10 more """?[39m, ?[32m"kafka_dlt-original-topic"?[39m -> ?[32m"topic-failed"?[39m, ?[32m"kafka_dlt-original-partition"?[39m -> ?[32m"\u0000\u0000\u0000\u0000"?[39m, ?[32m"kafka_dlt-original-offset"?[39m -> ?[32m"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000"?[39m, ?[32m"kafka_dlt-original-timestamp"?[39m -> ?[32m"\u0000\u0000\u0001�\u0003���"?[39m, ?[32m"kafka_dlt-original-timestamp-type"?[39m -> ?[32m"CreateTime"?[39m, ?[32m"kafka_dlt-original-consumer-group"?[39m -> ?[32m"group_id"?[39m ) ), partition = ?[32m0?[39m, key = ?[32m""?[39m, timestamp = ?[32m1765293196006L?[39m, offset = ?[32m0L?[39m, valueAsString = ?[32m"\"this message is coming from publish and consume with failed consumer and testName is publish and consume with failed consumer\""?[39m ) ) Published: ?[33mList?[39m( ?[33mPublished?[39m( topic = ?[32m"topic"?[39m, value = ?[33mByteArray?[39m(), metadata = ?[33mMessageMetadata?[39m( topic = ?[32m"topic"?[39m, key = ?[32m"null"?[39m, headers = ?[33mMap?[39m(?[32m"x-user-id"?[39m -> ?[32m"1486549027"?[39m) ), partition = ?[32mnull?[39m, key = ?[32m""?[39m, timestamp = ?[32mnull?[39m, valueAsString = ?[32m"\"this message is coming from publish and consume and testName is publish and consume\""?[39m ), ?[33mPublished?[39m( topic = ?[32m"topic-failed"?[39m, value = ?[33mByteArray?[39m(), metadata = ?[33mMessageMetadata?[39m( topic = ?[32m"topic-failed"?[39m, key = ?[32m"null"?[39m, headers = ?[33mMap?[39m(?[32m"x-user-id"?[39m -> ?[32m"-1909654526"?[39m) ), partition = ?[32mnull?[39m, key = ?[32m""?[39m, timestamp = ?[32mnull?[39m, valueAsString = ?[32m"\"this message is coming from publish and consume with failed consumer and testName is publish and consume with failed consumer\""?[39m ), ?[33mPublished?[39m( topic = ?[32m"topic"?[39m, value = ?[33mByteArray?[39m(), metadata = ?[33mMessageMetadata?[39m( topic = ?[32m"topic"?[39m, key = ?[32m"null"?[39m, headers = ?[33mMap?[39m(?[32m"x-user-id"?[39m -> ?[32m"-459857481"?[39m) ), partition = ?[32mnull?[39m, key = ?[32m""?[39m, timestamp = ?[32mnull?[39m, valueAsString = ?[32m"\"this message is coming from publish with ser/de and testName is publish with ser/de\""?[39m ), ?[33mPublished?[39m( topic = ?[32m"topic-failed-dlt"?[39m, value = ?[33mByteArray?[39m(), metadata = ?[33mMessageMetadata?[39m( topic = ?[32m"topic-failed-dlt"?[39m, key = ?[32m"null"?[39m, headers = ?[33mMap?[39m( ?[32m"x-user-id"?[39m -> ?[32m"-1909654526"?[39m, ?[32m"kafka_dlt-exception-fqcn"?[39m -> ?[32m"org.springframework.kafka.listener.ListenerExecutionFailedException"?[39m, ?[32m"kafka_dlt-exception-cause-fqcn"?[39m -> ?[32m"com.trendyol.stove.testing.e2e.kafka.StoveBusinessException"?[39m, ?[32m"kafka_dlt-exception-message"?[39m -> ?[32m"Listener method \'public final void com.trendyol.stove.testing.e2e.kafka.stringserde.KafkaTestSpringBotApplicationForStringSerde.listenFailed(java.lang.String)\' threw exception; This exception is thrown intentionally for testing purposes."?[39m, ?[32m"kafka_dlt-exception-stacktrace"?[39m -> ?[32m"""org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public final void com.trendyol.stove.testing.e2e.kafka.stringserde.KafkaTestSpringBotApplicationForStringSerde.listenFailed(java.lang.String)' threw exception at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2994) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2901) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2865) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2777) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2614) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2503) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2152) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1528) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1466) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1335) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804) at java.base/java.lang.Thread.run(Thread.java:840) Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2887) Caused by: com.trendyol.stove.testing.e2e.kafka.StoveBusinessException: This exception is thrown intentionally for testing purposes. at com.trendyol.stove.testing.e2e.kafka.stringserde.KafkaTestSpringBotApplicationForStringSerde.listenFailed(app.kt:106) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:569) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169) at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45) at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119) at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475) at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85) at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2887) ... 10 more """?[39m, ?[32m"kafka_dlt-original-topic"?[39m -> ?[32m"topic-failed"?[39m, ?[32m"kafka_dlt-original-partition"?[39m -> ?[32m"\u0000\u0000\u0000\u0000"?[39m, ?[32m"kafka_dlt-original-offset"?[39m -> ?[32m"\u0000\u0000\u0000\u0000\u0000\u0000\u0000\u0000"?[39m, ?[32m"kafka_dlt-original-timestamp"?[39m -> ?[32m"\u0000\u0000\u0001�\u0003���"?[39m, ?[32m"kafka_dlt-original-timestamp-type"?[39m -> ?[32m"CreateTime"?[39m, ?[32m"kafka_dlt-original-consumer-group"?[39m -> ?[32m"group_id"?[39m ) ), partition = ?[32m0?[39m, key = ?[32m""?[39m, timestamp = ?[32mnull?[39m, valueAsString = ?[32m"\"this message is coming from publish and consume with failed consumer and testName is publish and consume with failed consumer\""?[39m ) ) Failed: ?[33mList?[39m( ?[33mFailed?[39m( topic = ?[32m"topic-failed"?[39m, value = ?[33mByteArray?[39m(), metadata = ?[33mMessageMetadata?[39m( topic = ?[32m"topic-failed"?[39m, key = ?[32m"null"?[39m, headers = ?[33mMap?[39m(?[32m"x-user-id"?[39m -> ?[32m"-1909654526"?[39m) ), partition = ?[32m0?[39m, key = ?[32m""?[39m, timestamp = ?[32m1765293195420L?[39m, reason = com.trendyol.stove.testing.e2e.kafka.StoveBusinessException: This exception is thrown intentionally for testing purposes., valueAsString = ?[32m"\"this message is coming from publish and consume with failed consumer and testName is publish and consume with failed consumer\""?[39m ) )