В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

pro.kafka

1629 membersпожаловаться на группу
2020 March 07

VG

Vik Gamov in pro.kafka
весь проект
источник
22:27пожаловаться#1

VG

Vik Gamov in pro.kafka
Я хз что там ещё за конфиги
источник
22:28пожаловаться#2

I

Ivan in pro.kafka
ConsumerFactory
источник
22:28пожаловаться#3

I

Ivan in pro.kafka
вот тут скорей всего косяк
источник
22:28пожаловаться#4

I

Ivan in pro.kafka
пришли что у тебя там
источник
22:28пожаловаться#5

I

Ivan in pro.kafka
@sander92
источник
22:30пожаловаться#6

I

Ivan in pro.kafka
https://www.baeldung.com/spring-kafka
Baeldung
Intro to Apache Kafka with Spring | Baeldung
A quick and practical guide to using Apache Kafka with Spring.
источник
22:30пожаловаться#7

S🕶

Sander 🕶 in pro.kafka
Ivan
ConsumerFactory
https://pastebin.com/Bcqh0aMS
Pastebin
[Java] package com.example.application.configs.kafka;    import com.example.application - Pastebin.com
источник
22:30пожаловаться#8

I

Ivan in pro.kafka
вот тут hello-word лежит
источник
22:30пожаловаться#9

S🕶

Sander 🕶 in pro.kafka
Ivan
https://www.baeldung.com/spring-kafka
Baeldung
Intro to Apache Kafka with Spring | Baeldung
A quick and practical guide to using Apache Kafka with Spring.
читал я это
источник
22:30пожаловаться#10

S🕶

Sander 🕶 in pro.kafka
Sander 🕶
@Bean
public ConcurrentKafkaListenerContainerFactory<String, CreateTicketCommand> createTicketListenerContainerFactory() {
 ConcurrentKafkaListenerContainerFactory<String, CreateTicketCommand> factory = new ConcurrentKafkaListenerContainerFactory<>();
 factory.setConsumerFactory(genericConsumerFactory(CreateTicketCommand));
 return factory;
}
у меня string обычный будет отправлять без проблем, но любой кастомный object - он не дает,
только если вот это сверху прописать у листенера containerFactory = "${container.factory.create-ticket}".
источник
22:31пожаловаться#11

S🕶

Sander 🕶 in pro.kafka
Sander 🕶
https://pastebin.com/Bcqh0aMS
Pastebin
[Java] package com.example.application.configs.kafka;    import com.example.application - Pastebin.com
посмотрите пожалуйста конфигурацию @IvanBurlutskiy может найдете ошибку
источник
22:32пожаловаться#12

I

Ivan in pro.kafka
ConsumerFactory
источник
22:33пожаловаться#13

I

Ivan in pro.kafka
в личку кинь
источник
22:33пожаловаться#14

I

Ivan in pro.kafka
ссыль только завтра смогу посмотреть
источник
22:33пожаловаться#15

VG

Vik Gamov in pro.kafka
Sander 🕶
https://pastebin.com/Bcqh0aMS
Pastebin
[Java] package com.example.application.configs.kafka;    import com.example.application - Pastebin.com
Пропиши fdqn пакета с cricketticket в trusPackages.
источник
22:44пожаловаться#16

S🕶

Sander 🕶 in pro.kafka
Vik Gamov
Пропиши fdqn пакета с cricketticket в trusPackages.
простите я не понял что мне надо сделать
источник
22:46пожаловаться#17

VG

Vik Gamov in pro.kafka
Sander 🕶
простите я не понял что мне надо сделать
config.put(JsonDeserializer.TRUSTED_PACKAGES, "package.where.domain.object.resides");
источник
22:47пожаловаться#18

S🕶

Sander 🕶 in pro.kafka
стоит props.put(JsonDeserializer.TRUSTED_PACKAGES, "*"); и путь я тоже пробовал добавить
источник
22:48пожаловаться#19

S🕶

Sander 🕶 in pro.kafka
и в applicaiton.properites стоит тоже - spring.kafka.consumer.properties.spring.json.trusted.packages=*
источник
22:49пожаловаться#20