카프카 리스너에게 주제를 동적으로 전달하는 방법은 무엇입니까?

Question

며칠 동안 Java DSL에서 키를 사용하여 주제를 카프카 리스너에 동적으로 전달하는 방법을 시도하고 있습니다. 주변에있는 사람이라면 누구든지이 일을 수행하기위한 가장 좋은 방법은 무엇인지에 관해 밝힐 수 있습니까?

Answer 1

"카프카 리스너에게 주제를 동적으로 전달할 수 없습니다"; 대신 프로그램 방식으로 리스너 컨테이너를 만들어야합니다.

Answer 2

실시간으로 주제를 동적으로 변경할 수 있습니다. !!!!

@Component 
public class StoppingErrorHandler implements ErrorHandler { 

    @Autowired 
    private KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry; 

    @Override 
    public void handle(Exception thrownException, ConsumerRecord<?, ?> record) { 
     ConcurrentMessageListenerContainer listenerContainer = (ConcurrentMessageListenerContainer)kafkaListenerEndpointRegistry.getListenerContainer("fence"); 
     ContainerProperties cp=listenerContainer.getContainerProperties(); 
     String[] topics =cp.getTopics(); 
     topics[0]="gaonb"; 
     listenerContainer.stop(); 
     listenerContainer.start(); 
    } 
}