с разными типами: CreateTicket, CreateTicket2, CreateTicket3?
только с одним методом работает, а на каждый @KafkaHandler нельзя добавить containerFactory.
@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) {
....
}
}
хотя бы скажите если не понятно о чем я.
Обсуждают сегодня