Да мне решение интересно - нашлось что-то удобное и красивое? Я через наследование делал как-то, но хотелось бы удобней, как в  boot.

не ненашел, оставил как ранее делал,
наследование не сильно удобно тоже

Жаль ) благодарю за ответ

мой вопрос выше бы, кто бы помог

org.springframework.kafka.KafkaException: No method found for class java.lang.String - всегда вот такая ошибка,
чего ему нехвтает? мне казалось я настроил kafka, чтоб работал с разными типами.

@KafkaHandler
private void createTicket(CreateTicketCommand command) {

Какая ошибка то?

мб потому что private?

так вот я ошибку написал, @user83595863018, я отправляю нормальные данные,
но после отправки в "commandHandler", ломается - так как он отправляет String:

this.template.send(
  new GenericMessage<>(
    new CreateTicketCommand(
      accountId,
      ticketDto.getCountry().getIso(),
      ticketType.valueOf(ticketDto.getType()),
      ticketDto.getAmount()
    ),
    Collections.singletonMap(KafkaHeaders.TOPIC, createticket)
  )
);

так и должно быть? мне казалось что я получу объект на конечной точке:

@KafkaHandler
private void createTicket(CreateTicketCommand command) {

работает только это, так как мы получаем String, то в этот handler он и попадает, а мне надо тот что с объектом:

@KafkaHandler
private void createTicket(String test) {

надо читать доку

можете хотя бы сказать, оно так и должно работать, что только String-a приходит в command handler? или это можно настроить,
чтоб данные handler с типом, потому что я уже пытался настроить! не получилось.

Вроде оно
https://docs.spring.io/spring-kafka/docs/2.1.x/reference/html/_reference.html#serdes

((

@user83595863018

@KafkaListener(topics = "${producer.topic.create-ticket}", containerFactory = "greetingKafkaListenerContainerFactory") - только с этой фигней заработало, как-то можно сделать так, чтоб не приходилось указывать factory, это ведь жесть - столько кода писать, чтоб просто туда-сюда сообщения отправлять.

Annotation that marks a method to be the target of a Kafka message listener on the specified topics. The containerFactory() identifies the KafkaListenerContainerFactory to use to build the Kafka listener container. If not set, a default container factory is assumed to be available with a bean name of kafkaListenerContainerFactory unless an explicit default has been provided through configuration.

If not set, a default container factory is assumed to be available with a bean name of kafkaListenerContainerFactory

как-то можно - это настроить так, чтоб из конфигурации по типу объекта command определял.? @user83595863018

:(

@KafkaListener(topics = "${producer.topic.create-ticket}", containerFactory = "greetingKafkaListenerContainerFactory")
не представляю как с этим можно вообще работать.

если у меня 5-пять методов и у каждог освой containerFactory, то как мне эти методы добавить, создавтаь на один метод по классу?