Size: a a a

2020 April 07

S🕶

Sander 🕶 in pro.kafka
Alex
поэтому и попросил посмотреть specific
KafkaSpecificRecordDeserializer впервые слышу хмм что это за класс такой
источник

A

Alex in pro.kafka
com.example.datacollector.UserCreatedEvent is in unnamed module of loader 'app';
com.example.datacollector.UserCreatedEvent is in unnamed module of loader org.springframework.boot.devtools.restart.classloader.RestartClassLoader @35233424
источник

S🕶

Sander 🕶 in pro.kafka
этот вопрос интересный, намек на то что на 8 джаве будет работать?
источник

A

Alex in pro.kafka
у вас оказался один из класлоадера вешего приложения
второй походу сгенерированный класс из девтула

одинаковые классы из разных класлоадеров не полетят
источник

A

Alex in pro.kafka
попробуйте, в 8 и 9+ немного разная логика класлоадеров ….
источник

A

Alex in pro.kafka
не вы первый страдаете
источник

S🕶

Sander 🕶 in pro.kafka
props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, KafkaSpecificRecordDeserialize.class.getName()); - такого класса даже нет у меня
источник

S🕶

Sander 🕶 in pro.kafka
эээ серьезно, а чистый jar файл заработал
источник

S🕶

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

S🕶

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

ὦan in pro.kafka
В чем может быть проблема?
Есть брокер, зукипер и приложение - все в докере по отдельности и это работало (девопсы клянутся что ничего не меняли) пока внезапно не стало срать в логи
брокер пишет
Unable to read additional data from server sessionid 0x105ffcf702b00e0, likely server has closed socket, closing socket connection and attempting reconnect

Приложение пишет
1 partitions have leader brokers without a matching listener, including [credit-product-topic-0]


Zookeeper пишет
Refusing session request for client /10.0.0.4:48886 as it has seen zxid 0x3ea our last zxid is 0x2d6 client must try another server
Чет не могу сообразить в какую сторону копать
источник

AU

Andrey Ustinov in pro.kafka
а приложение через ЗК ходит что-ли?
источник

AU

Andrey Ustinov in pro.kafka
ну и еще, магии не бывает, если работало а потом перестало то скорее всего были изменения внесены
источник

ὦan in pro.kafka
Andrey Ustinov
а приложение через ЗК ходит что-ли?
Проще некуда - 1 брокер с парой топиков
источник

ὦan in pro.kafka
Попробую зукипер и брокер рестартануть
источник

AU

Andrey Ustinov in pro.kafka
я к тому, что попробуйте в приложении указать сразу брокер а не ЗК
источник

ὦan in pro.kafka
Andrey Ustinov
я к тому, что попробуйте в приложении указать сразу брокер а не ЗК
В приложении указан урл как на ЗК, так и на брокер
источник

ὦan in pro.kafka
Рестарт кипера и брокера не помог - хм
источник

AU

Andrey Ustinov in pro.kafka
ЗК не вижу причин трогать, проверьте консольником что брокер рабочий (что-то написать в топик и почитать) и в приложении убрать подкл через ЗК
источник

ὦan in pro.kafka
Andrey Ustinov
ЗК не вижу причин трогать, проверьте консольником что брокер рабочий (что-то написать в топик и почитать) и в приложении убрать подкл через ЗК
Сейчас попробую идею с брокером
источник