spring-kafka-test Examples and Free Source Code

Kafka transactional producer throws 'Timeout expired while initializing transactional state in 6...

java apache-kafka spring-kafka spring-transactions spring-kafka-test

Embedded Kafka test cases are error after adding jsonschema2pojo-core...

spring-kafka jsonschema2pojo spring-kafka-test

How to unit test Spring Cloud Stream with Kafka Streams...

apache-kafka-streams spring-cloud-stream spring-kafka-test spring-cloud-stream-binder-kafka

How to test a kafka consumer against a real kafka broker running on a server?...

spring-kafka spring-kafka-test

Kafka exactly once messaging test with "consume-transform-produce" Integration test...

spring-kafka spring-kafka-test

How to do integration testing of KStream topology using spring-boot EmbeddedKafka?...

apache-kafka apache-kafka-streams spring-kafka spring-kafka-test

How to wrap a @KafkaListener which is handled by seekToCurrentErrorHandler with a latch for testing...

java spring-boot apache-kafka spring-kafka spring-kafka-test

Exception while testing Spring Kafka error handler for @KafkaListener...

java spring-boot apache-kafka spring-kafka spring-kafka-test

Error creating bean with name 'embeddedKafka': Invocation of init method failed...

spring-boot spring-kafka junit5 java-11 spring-kafka-test

java.lang.NoClassDefFoundError: scala/collection/GenTraversableOnce at kafka.utils.TestUtils.tempDir...

scala spring-boot apache-kafka spring-kafka spring-kafka-test

Spring Boot and Kafka upgrade broke my tests...

spring spring-boot kotlin spring-kafka spring-kafka-test

java.lang.ClassNotFoundException: org.apache.jute.OutputArchive with latest spring-kafka and spring-...

spring-boot spring-kafka spring-boot-test spring-kafka-test

Spring Kafka integration test Error while writing to highwatermark file...

java spring-boot apache-kafka spring-kafka spring-kafka-test

AggregatingReplyingKafkaTemplate releaseStrategy Question...

spring spring-kafka spring-kafka-test

Spring kafka unit test listener not subscribing to topic...

spring spring-boot apache-kafka spring-kafka spring-kafka-test

KStream to KTable Inner Join producing different number of records every time processed with same da...

apache-kafka apache-kafka-streams spring-kafka spring-kafka-test

spring Kafka integration testing with embedded Kafka...

java spring-boot apache-kafka spring-kafka spring-kafka-test

How to set up Spring Kafka test using EmbeddedKafkaRule/ EmbeddedKafka to fix TopicExistsException I...

spring-boot kotlin apache-kafka spring-kafka spring-kafka-test

How to Create Integration Test for Spring Kafka Listener...

java spring spring-kafka junit5 spring-kafka-test

EmbeddedKafka not working cause an Scala error...

spring-boot spring-kafka spring-kafka-test

Getting Exceptions during KafkaTest eventhough the test passes...

spring-boot apache-kafka spring-kafka spring-kafka-test

Spring Embedded Kafka using Kafka 2.2.x...

apache-kafka-streams spring-kafka spring-io spring-kafka-test

Can't use a @KafkaListener more than once in a Test...

spring-kafka spring-cloud-stream spring-kafka-test

Spring Kafka (2.2.7.RELEASE) with. kafka-clients:2.2.1 IOException during embedded broker startup...

apache-kafka spring-kafka spring-kafka-test

Unit Test KafkaMessageListenerContainer...

java spring junit spring-kafka spring-kafka-test

Unit testing MessageListener class...

java junit mockito spring-kafka spring-kafka-test

spring Kafka integration test listener not working...

java spring-boot spring-kafka spring-kafka-test

How can you verify immediately that a message was acknowledged when integration testing using Embedd...

apache-kafka integration-testing spring-cloud-stream spring-kafka-test embedded-kafka

How to trigger and handle these Spring Kafka events...

spring-kafka spring-kafka-test

Spring Kafka @SendTo Not Sending Headers...

spring apache-kafka spring-kafka spring-kafka-test