Spring Boot Kafka с ручным управлением

Question

Обращаясь к Spring kafka doc , я пытаюсь реализовать приложение весенней загрузки, которое прослушивает тему kafka и проверяет вручную.

@SpringBootApplication
public class TestApplication {

  public static void main(String[] args) {
    SpringApplication.run(TestApplication.class, args);
  }

  @KafkaListener(topics = "sample_log", containerFactory = "kafkaManualAckListenerContainerFactory")
  public void listen(ConsumerRecord<?, ?> cr, Acknowledgment ack) throws Exception {
      process(cr);
      ack.acknowledge();
  }
}

Но когда я запустил приложение, оно показывает:

***************************
APPLICATION FAILED TO START
***************************
Description:
A component required a bean named 'kafkaManualAckListenerContainerFactory' that could not be found.
Action:
Consider defining a bean named 'kafkaManualAckListenerContainerFactory' in your configuration.

Насколько мне известно, Spring Kafka, возможно, определил бин kafkaManualAckListenerContainerFactory, поскольку он является предоставляемой функцией. Как я могу исправить ошибку, БЕЗ определения вручную бина?

Answer 1

Вам не нужна эта containerFactory = "kafkaManualAckListenerContainerFactory" конфигурация.Просто удалите его полностью и положитесь на предоставляемую Spring Boot автоконфигурацию для Kafka: https://docs.spring.io/spring-boot/docs/2.0.1.RELEASE/reference/htmlsingle/#boot-features-kafka