spring-kafka-test Questions
3
I am trying to do integration test for app that using kafka, kafka-streams and cassandra. But when I am trying to setUp test class, i've got 2 errors:
ERROR [main] BrokerMetadataCheckpoint: Failed...
Kish asked 25/1, 2019 at 11:59
2
Solved
I implemented a bunch of integration tests using EmbededKafka to test one of our Kafka streams application running using spring-kafka framework.
The stream application is reading a message from a ...
Valera asked 16/6, 2020 at 6:34
1
We have an integration test where we use EmbeddedKafka and produce a message to a topic, our app processes that message, and the result is sent to a second topic where we consume and assert the out...
Aikens asked 18/3, 2021 at 20:12
7
Solved
e: this has been fixed through Spring Boot 2.6.5 (see https://github.com/spring-projects/spring-boot/issues/30243)
Since upgrading to Spring Boot 2.6.X (in my case: 2.6.1), I have multiple projects...
Scalawag asked 9/12, 2021 at 15:22
2
I have created the below test class to produce an event using AvroSerializer.
@SpringBootTest
@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:9092", &...
Quechua asked 11/3, 2021 at 3:14
1
I'm writing a Kafka integration test for a simple Spring Boot application. The application simple publishes to a Kafka topic.
I am using an Embedded Kafka instance for the test. The test works perf...
Mcwherter asked 2/9, 2021 at 19:43
3
Solved
I am trying to connect to Kafka 3.0 with SSL but facing issue with loading SSL keystore
I have tried many possible values, but no help
I have tried changing the locations, changing the value of t...
Birkett asked 7/11, 2019 at 11:42
3
We are doing some integration test for out application using Cucumber and we are having some issues testing a @KafkaListener. We managed to use an EmbeddedKafka and produce data into it.
But the ...
Webbed asked 11/3, 2020 at 15:39
3
Solved
I'm writing integration test using spring-kaka-2.2.0 in spring boot application, I'm nearly succeeded still my test case return true but still I see multiple error after that.
2019-02-21 11:12:35....
Delacroix asked 21/2, 2019 at 17:35
1
Solved
I want to load my spring-kafka properties from application.properties and that must be loaded using spring auto configuration. My problem is Caused by: java.lang.IllegalStateException: No Acknowled...
Monteria asked 25/3, 2020 at 0:34
1
Solved
I've written a test class for kafka stream application as per https://kafka.apache.org/24/documentation/streams/developer-guide/testing.html
, the code for which is
import com.EventSerde;
import or...
Automatism asked 30/1, 2020 at 14:2
2
I have a simple Spring Boot application which reads from Kafka and writes to Kafka. I wrote a SpringBootTest using an EmbeddedKafka to test all that.
The main problem is: Sometimes the test fails ...
Myatt asked 10/4, 2019 at 17:41
1
Solved
This is wired just started spring boot project with simple main class, it works fine without spring-kafka dependency but after adding spring-kafka and spring-kafka-test blows up with exception, git...
Colicweed asked 17/12, 2018 at 1:40
1
© 2022 - 2024 — McMap. All rights reserved.