Size: a a a

2020 April 07

М

Михаил in pro.kafka
Alex
Запустите 4 инстанса и один будет ждать свободного места
Понял, спасибо!
источник

S🕶

Sander 🕶 in pro.kafka
не понимаю, снова проблемы с этой kafka, получаю данные System.out.println("userCreatedEvent: " + record.value());,
но если пытаюсь достать пропертю record.value().getFirstName(), то падает с ошибкой ...
источник

S🕶

Sander 🕶 in pro.kafka
источник

A

Alex in pro.kafka
class com.example.datacollector.UserCreatedEvent cannot be cast to class com.example.datacollector.UserCreatedEvent
источник

A

Alex in pro.kafka
java serialization ?
источник

S🕶

Sander 🕶 in pro.kafka
я предпологаю что да, но я использую  схемы avro, он генерирует pojo, я думал с serialize не должно быть проблем. @xhumanoid
источник

S🕶

Sander 🕶 in pro.kafka
источник

A

Alex in pro.kafka
нет, авро как раз таки по позволяет в бинарь собственного формата сериализовать вместо стандартной джавовой
источник

S🕶

Sander 🕶 in pro.kafka
источник

S🕶

Sander 🕶 in pro.kafka
Alex
нет, авро как раз таки по позволяет в бинарь собственного формата сериализовать вместо стандартной джавовой
мне казалось с ним не будет проблем и тип предоставляют GenericRecord, вместо object, собственно что прошлый раз мучался несколько ночей - кое как через костыли сделал, что было совсем не расширяемо,
что в этот раз решил сделать по другому и тоже не работает.
источник

S🕶

Sander 🕶 in pro.kafka
данные то получаю я их вижу, но сразу как я собираюсь получить от туда property, из этих данных, то все он падает с ошибкой.
источник

S🕶

Sander 🕶 in pro.kafka
источник

S🕶

Sander 🕶 in pro.kafka
может сможете подсказать, что я не так делаю тут?(
источник

A

Alex in pro.kafka
обычный KafkaAvroDeserializer генерит схему и классы на лету, поэтому у вас и ошибка, так как на выходе у него даже по апи
попробуйте KafkaSpecificRecordDeserializer
источник

S🕶

Sander 🕶 in pro.kafka
у меня по сути сделано как тут https://www.confluent.io/blog/schema-registry-avro-in-spring-boot-application-tutorial/,
взял их код запустил и там точно такая же проблема.
источник

A

Alex in pro.kafka
запустили на 11 джава =)
источник

S🕶

Sander 🕶 in pro.kafka
Alex
обычный KafkaAvroDeserializer генерит схему и классы на лету, поэтому у вас и ошибка, так как на выходе у него даже по апи
попробуйте KafkaSpecificRecordDeserializer
я создал схему и сгенерировал классы сам
источник

S🕶

Sander 🕶 in pro.kafka
Alex
запустили на 11 джава =)
12
источник

A

Alex in pro.kafka
поэтому и попросил посмотреть specific
источник

A

Alex in pro.kafka
хотя может и не спасёт
источник