Примеры здесь .
Соответствующий бит:
@Autowired
private KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry;
public String start() {
MessageListenerContainer listenerContainer = kafkaListenerEndpointRegistry.getListenerContainer("fooGroup");
listenerContainer.start();
...
}
@KafkaListener(id = "fooGroup", topics = "topic1", autoStartup = "false")
public void listen(Foo2 foo) {
...
}
Оригинал: “https://dev.to/arsenalist/starting-and-stopping-a-kafka-listener-after-spring-boot-startup-459g”