ведь они разные везде будут 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 нельзя, я в тупике.
Обсуждают сегодня