L
sources
Size: a a a
L
L
L
L
S🕶
containerFactory = "${container.factory.create-ticket}"
? на каждый handler, ведь они разные везде будут 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) {
....
}
}
S🕶
containerFactory = "${container.factory.create-ticket}"
? на каждый handler, ведь они разные везде будут 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) {
....
}
}
containerFactory
?containerFactory
не работает? добавить на каждый @KafkaHandler
нельзя, я в тупике.ПГ
GD
V
GD
V
GD
N
ДЧ
SK