Как правильно создать потребителя для интеграционного теста, чтобы проверить, было ли сообщение отправлено кафке?
#java #spring-boot #apache-kafka #spring-cloud #spring-cloud-stream Вопрос: Я использую avro для создания класса java (Сердцебиение), и я использую процессор обмена сообщениями Spring cloud, чтобы отправить сообщение кафке, используя этот класс сердцебиения.…