Описание тега spring-kafka-test
1
ответ
Получить данные из темы после нажатия на @EmbeddedKafka в весенней загрузке Junit
Я пишу тестовые примеры Junit (используя @EmbeddedKafka) для своего приложения Spring Boot, которое широко использует Spring-kafka для связи с другими сервисами и для других операций. Один типичный случай - удаление данных из kafka (что мы делаем с …
31 янв '19 в 03:30
1
ответ
Весеннее интеграционное тестирование Kafka со встроенным Kafka
У меня есть весеннее загрузочное приложение, которое потребляет потребителя из одной темы в одном кластере и создает другую тему в другом кластере. Сейчас я пытаюсь написать интеграционный тестовый пример, используя Spring Kafka, но у меня возникла …
18 фев '19 в 20:11
1
ответ
Весенний слушатель теста интеграции Kafka не работает
Я пытаюсь тестирование интеграции с помощью spring-boot и весной врезал кафку. Я могу создать сообщение для встроенного в Kafka сервера, но вместо тестового слушателя слушатель в классе обслуживания пытается использовать записи и KafkaProducerConfig…
19 фев '19 в 19:37
1
ответ
Обновите spring-kafka-test до 2.2.x, но все еще используйте старый kafka-client 1.1.1 с junit5 и spring boot 2
В настоящее время я использую spring boot 2 и junit 5. Я хочу использовать spring-kafka-test для тестирования, однако версия spring-kafka, которую я использую, - 2.1.8.RELEASE. С этим я считаю, что его невозможно использовать EmbeddedKafkaBroker так…
23 янв '19 в 22:13
0
ответов
Интеграция Spring Kafka с Embbeded Kafka
У меня есть загрузочное приложение Spring, которое будет принимать и выводить сообщения на разные темы, сейчас я пытаюсь написать интеграционный тестовый пример, используя встроенный Spring Kafka. При запуске теста у меня есть проблема: Caused by: o…
25 фев '19 в 23:27
0
ответов
Как исправить ошибку от встроенной кафки, которая не может найти meta.properties
Я пытаюсь сделать интеграционный тест для приложения, использующего kafka, kafka-streams и cassandra. Но когда я пытаюсь установить тестовый класс, у меня есть 2 ошибки: ОШИБКА [main] BrokerMetadataCheckpoint: не удалось прочитать файл meta.properti…
25 янв '19 в 11:59
1
ответ
Spring kafka error Причина: java.lang.ClassNotFoundException: org.springframework.kafka.transaction.KafkaAwareTransactionManager
Это связано с тем, что только что начал весенний загрузочный проект с простым основным классом, он работает нормально без зависимости spring-kafka, но после добавления spring-kafka а также spring-kafka-test взрывается с исключением, github здесь gra…
17 дек '18 в 01:40
2
ответа
Отправка с использованием KafkaTemplate<String, String> возвращает исключение для использования String в качестве ключа
При использовании Integer в качестве ключа это не проблема, kafka должен иметь возможность обрабатывать строки как ключ. ProducerFactory<String, String> pf = new DefaultKafkaProducerFactory<String, String>(senderProps); KafkaTemplate<…
03 янв '19 в 09:12
1
ответ
Тест интеграции Spring Kafka Ошибка при записи в файл highwatermark
Я пишу интеграционный тест с использованием spring-kaka-2.2.0 в приложении весенней загрузки, мне почти все-таки удалось, мой тестовый набор вернул true, но после этого я вижу множественные ошибки. 2019-02-21 11:12:35.434 ERROR 5717 --- [ Thread-7] …
21 фев '19 в 17:35
1
ответ
Как вызвать и обработать эти события Spring Kafka
В моем проекте Spring Boot, где у меня есть несколько потребителей Spring Kafka, я добавил несколько слушателей событий, чтобы следить за состоянием этих потребителей. Вот код: @Component public class ApplicationContextListeningService { @EventListe…
06 май '19 в 21:45
1
ответ
После обновления kafka до 2.x мой UT не может быть запущен после использования последней версии EmbeddedKafkaRule
Моя тестовая зависимость связана с кафкой, как показано ниже: | +--- org.apache.kafka:kafka_2.11:2.0.0 -> 2.0.1 | | +--- org.apache.kafka:kafka-clients:2.0.1 -> 2.1.1-cp1 | +--- org.apache.kafka:kafka-clients:2.0.0 -> 2.1.1-cp1 (*) | +--- i…
09 мар '19 в 00:18
0
ответов
@EmbeddedKafka ошибки выключения
@EmbeddedKafka выдает кучу ошибок при завершении работы. Есть ли способ предотвратить это? Трудно найти реальные ошибки. происходит как на MacOS, так и на контейнере Linux Config (пришлось установить реплики в 1, чтобы он работал): @EmbeddedKafka( c…
22 мар '19 в 05:59
1
ответ
Встроенные сообщения обновления Kafka между тестами
Я использую Spring Kafka с @EmbeddedKafka аннотация для запуска экземпляра Embedded kafka. Зависимость: <dependency> <groupId>org.springframework.kafka</groupId> <artifactId>spring-kafka-test</artifactId> <scope>t…
10 апр '19 в 15:00
1
ответ
Как я могу протестировать метод с аннотацией @KafkaListener в приложении весенней загрузки?
У меня есть spring компонент с @KafkaListener метод: @Slf4j @Component public class ResponseHandler { private final ResponseMessageService responseMessageService; public ResponseHandler(ResponseMessageService responseMessageService) { this.responseM…
15 апр '19 в 11:48
2
ответа
Как протестировать потребителя кафки против реального брокера кафки, работающего на сервере?
У меня возникают трудности с пониманием некоторых концепций Kafka в Java Spring Boot. Я хотел бы протестировать потребителя с реальным брокером Kafka, работающим на сервере, у которого есть несколько производителей, которые пишут / уже писали данные…
08 май '19 в 15:23
1
ответ
SpringBootTest завершится неудачно, если приложение содержит аннотацию @KafkaListener
Я создаю новый весенний загрузочный проект с простым тестом: @RunWith(SpringRunner.class) @SpringBootTest public class ExampleApplicationTests { @Test public void contextLoads() { } } Когда я запускаю этот тест, он проходит успешно. Но если я добавл…
14 май '19 в 10:47
1
ответ
Spring Kafka @SendTo не отправляет заголовки
Я отправляю сообщение Кафке, используя ReplyingKafkaTemplate и он отправляет сообщение с kafka_correlationId, Тем не менее, когда он попадает в мой @KafkaListener метод и перенаправляет его в тему ответа, заголовки теряются. Как мне сохранить заголо…
10 апр '19 в 22:37
2
ответа
Spring KafkaListener: как узнать, когда он будет готов
У меня есть простое приложение Spring Boot, которое читает из Kafka и пишет в Kafka. Я написал SpringBootTest используя EmbeddedKafka чтобы проверить все это. Основная проблема: иногда тест не проходит, потому что тест отправляет сообщение Kafka сли…
10 апр '19 в 17:41
2
ответа
Как настроить порт в KafkaEmbedded при юнит-тестировании Spring-Kafka-потребителя
Я использую spring-boot-starter-parent версия 1.5.0.RELEASE, spring-kafka версия 1.0.0.RELEASE а также spring-kafka-test версия 1.0.0.RELEASE в приложении, которое потребляет сообщения от Kakfa 0.9 кластер. У меня есть юнит-тест для моего потребител…
20 май '19 в 17:12
0
ответов
Как правильно использовать @EmbeddedKafka для IntegrationTests?
Я прочитал документацию по spring-kafka, примеры, которые я нашел, и половину стека overflow, но я не понимаю, кто должен работать @EmbeddedKafka. Специально для интеграционных тестов. @RunWith(SpringRunner.class) @SpringBootTest(webEnvironment = Sp…
17 июн '19 в 13:39