Я пытаюсь выполнить интеграционное тестирование с использованием spring-boot и встроенного Spring Kafka. Я могу создать сообщение для встроенного сервера Kafka Spring, но вместо тестового слушателя слушатель в классе обслуживания пытается...

Я в основном успешно настраивал тест с использованием EmbeddedKafka, который создает и использует одно сообщение. Ниже представлена ​​рабочая версия теста: @RunWith(SpringRunner.class) @SpringBootTest @EmbeddedKafka public class KafkaFlowTest {...

Я использую spring kafka со встроенной kafka для теста JUnit, он выдает ошибку для каждого теста в Windows: Error deleting C:\Users:LXX691\AppData\Local\Temp\kafka-1103610162480947200/.lock: The process cannot access the file because it is being...

Я пишу потоковое приложение с Kafka Streams, Spring-Kafka и Spring Boot. Я не могу найти никакой информации, как правильно протестировать потоковую обработку, выполняемую Kafka Streams DSL при использовании Spring-Kafka. В документации упоминается...

Я запускаю тест Junit с использованием EmbeddedKafka, я могу производить и использовать для брокеров embeddedKafka и успешно подтверждать отправленные мной данные. Но я вижу много исключений в трассировке стека, которая происходит после того, как...

Я написал тестовый класс для приложения потока kafka согласно https://kafka.apache.org/24/documentation/streams/developer-guide/testing.html , код которого import com.EventSerde; import org.apache.kafka.common.serialization.Serde; import...

Я хочу загрузить свои свойства spring-kafka из application.properties, которые должны быть загружены с использованием автоматической настройки spring. Моя проблема вызвана: java.lang.IllegalStateException: подтверждение недоступно в качестве...