Блог

У меня есть обратный вызов для событий Kafka с помощью Springboot:

 @KafkaHandler
fun consume(@Payload response: CustomObject) {
    ...
}
  

Когда я запускаю модульные тесты, все хорошо, все они проходят.

Как только я добавлю другую конечную точку:

 @KafkaHandler
fun debug0Consume(@Payload handle: String, @Payload response: CustomObject) {
    ...
}
  

Я ожидаю, что исходный обратный вызов consume(@Payload response: CustomObject) продолжит выполняться. Вместо этого ни один из двух обратных вызовов не выполняется.

Я поместил строки отладки в оба из них, и они не вызываются (помимо того факта, что все тесты, конечно, завершаются неудачей).

Что здесь происходит? Почему добавление нового прослушивателя событий Kafka приводит к тому, что Springboot framework не выполняет ни одно из них?

Моя общая цель — иметь возможность выполнять обратный вызов, который будет выполнен для следующего события:

 send(java.lang.String topic, String key, CustomObject info)