java.lang.AssertionError: GOT A TIMEOUT: While expecting the publish of 'Object'. 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"-2103970998"?[39m)
    ),
    partition = ?[32m0?[39m,
    key = ?[32m""?[39m,
    timestamp = ?[32m1765275310522L?[39m,
    offset = ?[32m0L?[39m,
    valueAsString = ?[32m"\"this message is coming from publish and consume and testName is publish and consume\""?[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"-2103970998"?[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-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"-1716111520"?[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�\u0002���"?[39m,
        ?[32m"kafka_dlt-original-timestamp-type"?[39m -> ?[32m"CreateTime"?[39m,
        ?[32m"kafka_dlt-original-consumer-group"?[39m -> ?[32m"group_id"?[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-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"-1716111520"?[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
  )
)
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"-1716111520"?[39m)
    ),
    partition = ?[32m0?[39m,
    key = ?[32m""?[39m,
    timestamp = ?[32m1765275311247L?[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
  )
)
	at _COROUTINE._BOUNDARY._(CoroutineDebugging.kt:42)
	at kotlinx.coroutines.TimeoutKt.withTimeoutOrNull(Timeout.kt:102)
	at io.kotest.engine.test.interceptors.InvocationTimeoutInterceptor.intercept(InvocationTimeoutInterceptor.kt:36)
	at io.kotest.engine.test.TestInvocationInterceptor$invokeWithRetry$2.invokeSuspend(TestInvocationInterceptor.kt:53)
	at io.kotest.engine.test.TestInvocationInterceptor.invokeWithRetry(TestInvocationInterceptor.kt:51)
	at io.kotest.engine.test.TestInvocationInterceptor.intercept(TestInvocationInterceptor.kt:33)
	at io.kotest.engine.interceptors.MarkPlatformAbortedExceptionsAsSkippedTestInterceptor.intercept(MarkPlatformAbortedExceptionsAsSkippedTestInterceptor.kt:22)
	at io.kotest.engine.test.interceptors.HandleSkippedExceptionsTestInterceptor.intercept(HandleSkippedExceptionsTestInterceptor.kt:15)
	at io.kotest.engine.test.interceptors.TimeoutInterceptor$intercept$3.invokeSuspend(TimeoutInterceptor.kt:54)
	at io.kotest.engine.test.interceptors.TimeoutInterceptor.intercept(TimeoutInterceptor.kt:53)
	at io.kotest.engine.test.interceptors.BlockedThreadTimeoutInterceptor.intercept(BlockedThreadTimeoutInterceptor.kt:87)
	at io.kotest.engine.test.interceptors.CoroutineLoggingInterceptor.intercept(CoroutineLoggingInterceptor.kt:36)
	at io.kotest.engine.test.interceptors.SoftAssertInterceptor.intercept(SoftAssertInterceptor.kt:26)
	at io.kotest.engine.test.interceptors.AssertionModeInterceptor.intercept(AssertionModeInterceptor.kt:29)
	at io.kotest.engine.test.interceptors.LifecycleInterceptor.intercept(LifecycleInterceptor.kt:48)
	at io.kotest.engine.test.interceptors.BeforeSpecListenerInterceptor.intercept(BeforeSpecListenerInterceptor.kt:51)
	at io.kotest.engine.test.interceptors.TestEnabledCheckInterceptor.intercept(TestEnabledCheckInterceptor.kt:39)
	at io.kotest.engine.test.interceptors.CoroutineErrorCollectorInterceptor$intercept$3.invokeSuspend(CoroutineErrorCollectorInterceptor.kt:39)
	at io.kotest.engine.test.interceptors.SupervisorScopeInterceptor$intercept$2.invokeSuspend(SupervisorScopeInterceptor.kt:23)
	at io.kotest.engine.test.interceptors.TestFinishedInterceptor.intercept(TestFinishedInterceptor.kt:23)
	at io.kotest.engine.test.FailFastInterceptor.intercept(FailFastInterceptor.kt:32)
	at io.kotest.engine.test.interceptors.TestNameContextInterceptor$intercept$2.invokeSuspend(TestNameContextInterceptor.kt:19)
	at io.kotest.engine.test.interceptors.DescriptorPathContextInterceptor$intercept$2.invokeSuspend(DescriptorPathContextInterceptor.kt:19)
	at io.kotest.engine.spec.execution.SingleInstanceSpecExecutor.executeTest(SingleInstanceSpecExecutor.kt:75)
	at io.kotest.engine.spec.execution.SingleInstanceSpecExecutor$launchRootTests$2$1$1.invokeSuspend(SingleInstanceSpecExecutor.kt:56)
Caused by: java.lang.AssertionError: GOT A TIMEOUT: While expecting the publish of 'Object'. 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"-2103970998"?[39m)
    ),
    partition = ?[32m0?[39m,
    key = ?[32m""?[39m,
    timestamp = ?[32m1765275310522L?[39m,
    offset = ?[32m0L?[39m,
    valueAsString = ?[32m"\"this message is coming from publish and consume and testName is publish and consume\""?[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"-2103970998"?[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-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"-1716111520"?[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�\u0002���"?[39m,
        ?[32m"kafka_dlt-original-timestamp-type"?[39m -> ?[32m"CreateTime"?[39m,
        ?[32m"kafka_dlt-original-consumer-group"?[39m -> ?[32m"group_id"?[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-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"-1716111520"?[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
  )
)
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"-1716111520"?[39m)
    ),
    partition = ?[32m0?[39m,
    key = ?[32m""?[39m,
    timestamp = ?[32m1765275311247L?[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
  )
)
	... 24 more
Caused by: java.lang.AssertionError: GOT A TIMEOUT: While expecting the publish of 'Object'. 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"-2103970998"?[39m)
    ),
    partition = ?[32m0?[39m,
    key = ?[32m""?[39m,
    timestamp = ?[32m1765275310522L?[39m,
    offset = ?[32m0L?[39m,
    valueAsString = ?[32m"\"this message is coming from publish and consume and testName is publish and consume\""?[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"-2103970998"?[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-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"-1716111520"?[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�\u0002���"?[39m,
        ?[32m"kafka_dlt-original-timestamp-type"?[39m -> ?[32m"CreateTime"?[39m,
        ?[32m"kafka_dlt-original-consumer-group"?[39m -> ?[32m"group_id"?[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-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"-1716111520"?[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
  )
)
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"-1716111520"?[39m)
    ),
    partition = ?[32m0?[39m,
    key = ?[32m""?[39m,
    timestamp = ?[32m1765275311247L?[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
  )
)
	at com.trendyol.stove.testing.e2e.kafka.TestSystemKafkaInterceptor.waitUntilConditionMet-NcHsxvU(TestSystemInterceptor.kt:180)
	at com.trendyol.stove.testing.e2e.kafka.TestSystemKafkaInterceptor.access$waitUntilConditionMet-NcHsxvU(TestSystemInterceptor.kt:25)
	at com.trendyol.stove.testing.e2e.kafka.TestSystemKafkaInterceptor$waitUntilConditionMet$1.invokeSuspend(TestSystemInterceptor.kt)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:34)
	at kotlinx.coroutines.internal.ScopeCoroutine.afterResume(Scopes.kt:35)
	at kotlinx.coroutines.AbstractCoroutine.resumeWith(AbstractCoroutine.kt:101)
	at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:47)
	at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:98)
	at kotlinx.coroutines.EventLoopImplBase.processNextEvent(EventLoop.common.kt:263)
	at kotlinx.coroutines.BlockingCoroutine.joinBlocking(Builders.kt:94)
	at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking(Builders.kt:70)
	at kotlinx.coroutines.BuildersKt.runBlocking(Unknown Source)
	at kotlinx.coroutines.BuildersKt__BuildersKt.runBlocking$default(Builders.kt:48)
	at kotlinx.coroutines.BuildersKt.runBlocking$default(Unknown Source)
	at io.kotest.engine.RunBlocking_jvmKt.runBlocking(runBlocking.jvm.kt:3)
	at io.kotest.engine.TestEngineLauncher.launch(TestEngineLauncher.kt:204)
	at io.kotest.runner.junit.platform.KotestJunitPlatformTestEngine.execute(KotestJunitPlatformTestEngine.kt:75)
	at io.kotest.runner.junit.platform.KotestJunitPlatformTestEngine.execute(KotestJunitPlatformTestEngine.kt:47)