Size: a a a

2021 July 10

R

Riccio in pro.kafka
есть ощущение, что во втором случае десериализованный объект в виде json`a отправляется как коллекция строк в виде массива байт. и его принять надо как коллекцию строк и пропускать через маппер
источник

VG

Vik Gamov in pro.kafka
Что в настройках value deserializer?
источник

R

Riccio in pro.kafka
consumer:
 group-id: my_group
 key-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2
 value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2
источник

R

Riccio in pro.kafka
уточнил ошибку:
Caused by: java.lang.IllegalStateException: No type information in headers and no default type provided
источник

R

Riccio in pro.kafka
но, повторюсь, другие запросы работают - данные десериализуются. уточню - десериализуются в объекты других классов. но все классы выполнены компиляцией в автоматическом режиме, они единообразны  и уже многократно отработаны
источник

VG

Vik Gamov in pro.kafka
Это все?
источник

R

Riccio in pro.kafka
Сейчас
источник

VG

Vik Gamov in pro.kafka
Вот. Jsonseriizer в спринге информацию о типе (классе) прописывает в хедере. Когда используешь spring cloud stream мне кажется по умолчанию используется json serializer.
источник

VG

Vik Gamov in pro.kafka
Когда используешь spring-kafka (твой второй пример) то по умолчанию используется кафковский Bytearrayserializer (не помню точное название, пишу с дивана и с телефона)
источник

R

Riccio in pro.kafka
consumer:
 group-id: my_group
 key-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2
 value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer2
 properties:
   spring:
     json.trusted.packages: '*'
     deserializer:
       key.delegate.class: org.apache.kafka.common.serialization.StringDeserializer
       value.delegate.class: my.package.ConfigurableJsonDeserializer
источник

R

Riccio in pro.kafka
my.package.ConfigurableJsonDeserializer возвращает сконфигурированный ObjectMapper из Jackson
источник

ON

Olzhas Nuralinov in pro.kafka
подскажите материал, как поднять кафку на винде
источник

VG

Vik Gamov in pro.kafka
источник
2021 July 11

II

Ilya Ilyukou in pro.kafka
Как отключить логирование для кафки в консоль?

[-StreamThread-1] o.a.k.s.processor.internals.TaskManager  :  
stream-thread [PROJECT_NAME-b3c12d47-8c00-491c-aa79-678ae7843613-StreamThread-1] Committing task offsets {}
источник

VG

Vik Gamov in pro.kafka
Как и везде. Там. Log4j
источник

VG

Vik Gamov in pro.kafka
И это лог стримов
источник

SD

Stanislav Dubrovsky in pro.kafka
а кто-нибудь использовал acknowledgement.nack() в спринг кафке, я ведь правильно понимаю, что сообщение будет отброшено, через таймаут снова вычитано и так будет вечный кайф?
источник
2021 July 12

KS

Kostya Struga in pro.kafka
да, норм тема
источник
2021 July 13

R

Riccio in pro.kafka
Спасибо, разобрался. Всё именно так.
Вопрос: могу ли я настроить десериализатор так, чтобы он автоматически распознавал тип из поступившего массива байт?
источник

TT

Testing Test in pro.kafka
Подскажите, пожалуйста, как можно ускорить процесс получения пробного ключа для Lenses? Ближайшая дата получения через менеджера на 20 июля
источник