Телеграмм чат группы proKafka страница 1248

я просто пытаюсь понять, что такое createTicket и ticketDto, чтоб понимать какие мне указывать.

10:14пожаловаться #1

S🕶

@ivan_ponomarev

10:14пожаловаться #2

Да это же то что ты сам придумываешь. Краткие прозвища типов. Логику можешь выдумать сам. В type_mapping ты прописываешь соотношение между «прозвищами» и реальными типами

10:35пожаловаться #3

Главное чтоб они были уникальные и последовательно одни и те же для одних и тех же типов

10:36пожаловаться #4

S🕶

я пока не смог запустить, работало только на вашем примере

10:37пожаловаться #5

Ну.... чутка повнимательнее и заработает))

10:38пожаловаться #6

S🕶

дайте немного времени пожалуйста, если не запустится я дам знать

10:38пожаловаться #7

S🕶

там какие-то новые ошибки

10:38пожаловаться #8

Там не знаю, для начала хотя бы с пробросом сообщений одного типа разберись

10:38пожаловаться #9

S🕶

2020-03-08 09:39:03.838 ERROR 70717 --- [nio-8080-exec-2] o.a.c.c.C.[.[.[.[dispatcherServlet]      : Servlet.service() for servlet [dispatcherServlet] in context with path [/api] threw exception [Request processing failed; nested exception is org.apache.kafka.common.errors.SerializationException: Can't convert value of class com.example.application.domain.CreateTicketCommand to class org.apache.kafka.common.serialization.StringSerializer specified in value.serializer] with root cause

java.lang.ClassCastException: class com.example.application.domain.CreateTicketCommand cannot be cast to class java.lang.String (com.example.application.domain.CreateTicketCommand is in unnamed module of loader org.springframework.boot.devtools.restart.classloader.RestartClassLoader @6ef66530; java.lang.String is in module java.base of loader 'bootstrap')

10:39пожаловаться #10

S🕶

сложно сказать 1 в 1 скопировал код

10:47пожаловаться #11

S🕶

скорей я ошибся, там не работало у него, логи перепутал.

11:09пожаловаться #12

S🕶

@ivan_ponomarev а ваш пример вы можете предоставить рабочий!?

11:09пожаловаться #13

Sander 🕶

@ivan_ponomarev а ваш пример вы можете предоставить рабочий!?

KafkaConsumerConfig.java

(2.17 Кб)

11:12пожаловаться #14

S🕶

Sander 🕶

2020-03-08 09:39:03.838 ERROR 70717 --- [nio-8080-exec-2] o.a.c.c.C.[.[.[.[dispatcherServlet]      : Servlet.service() for servlet [dispatcherServlet] in context with path [/api] threw exception [Request processing failed; nested exception is org.apache.kafka.common.errors.SerializationException: Can't convert value of class com.example.application.domain.CreateTicketCommand to class org.apache.kafka.common.serialization.StringSerializer specified in value.serializer] with root cause

java.lang.ClassCastException: class com.example.application.domain.CreateTicketCommand cannot be cast to class java.lang.String (com.example.application.domain.CreateTicketCommand is in unnamed module of loader org.springframework.boot.devtools.restart.classloader.RestartClassLoader @6ef66530; java.lang.String is in module java.base of loader 'bootstrap')

только с этой ошибкой падает

11:16пожаловаться #15

S🕶

____________
command.toString(): CreateTicketCommand(name=boom, id=42)
____________

@gamussa да у него работает, но пакеты у него другие в проекте и java 1.8

11:20пожаловаться #16

S🕶

может где бага в пакетах, уж не знаю

11:20пожаловаться #17

S🕶

spring.kafka.producer.properties.key-serializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.producer.properties.value-serializer=org.springframework.kafka.support.serializer.JsonSerializer

блин вот что еще нашел у него в настройках

11:20пожаловаться #18

S🕶

не помогло

11:21пожаловаться #19

S🕶

все робит