ведь они разные везде будут Command классы.
                  
                  
                  @KafkaListener(topics = "${producer.topic.create-ticket}", containerFactory = "${container.factory.create-ticket}")
                  
                  
                  @Service
                  
                  
                  public class TicketServiceCommandHandler {
                  
                  
                  
                  
                  
                   @KafkaHandler
                  
                  
                   private void createTicket(CreateTicket command) {
                  
                  
                                ....
                  
                  
                   }
                  
                  
                  
                  
                  
                         @KafkaHandler
                  
                  
                   private void createTicket(CreateTicketTest2 command) {
                  
                  
                                ....
                  
                  
                   }
                  
                  
                  
                  
                  
                           @KafkaHandler
                  
                  
                   private void createTicket(CreateTicketTest3 command) {
                  
                  
                                ....
                  
                  
                   }
                  
                  
                  }
                  
                  
                
1) как сделать чтоб работало без containerFactory? 2) без containerFactory не работает? добавить на каждый @KafkaHandler нельзя, я в тупике.
Обсуждают сегодня