Вопросы по теме 'embedded-kafka'
Kafka Streams: смешивание и сопоставление PAPI и DSL KTable без совместного разделения
У меня есть смешанная топология Scala, где основным рабочим является процессор PAPI, а другие части подключаются через DSL.
EventsProcessor:
INPUT: eventsTopic
OUTPUT: visitorsTopic (and others)
Данные по всем темам (включая исходный...
151 просмотров
schedule
02.11.2021
Как я могу протестировать метод с аннотацией @KafkaListener в приложении Spring-Boot?
У меня есть spring компонент с @KafkaListener методом:
@Slf4j
@Component
public class ResponseHandler {
private final ResponseMessageService responseMessageService;
public ResponseHandler(ResponseMessageService...
1697 просмотров
schedule
05.09.2021
