Size: a a a

2020 March 07

VG

Vik Gamov in pro.kafka
Sander 🕶
Spring Framework
источник

VG

Vik Gamov in pro.kafka
Есть репродьюсер где-нибудь?
источник

VG

Vik Gamov in pro.kafka
Ivan Ponomarev
Какой serde используешь?
Здается мне там не стримы
источник

S🕶

Sander 🕶 in pro.kafka
props.put(JsonDeserializer.TRUSTED_PACKAGES, "*"); - добавил эту строку ошибка не поменялась,
org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition create-ticket-0 at offset 63. If needed, please seek past the record to continue consumption.
Caused by: java.lang.IllegalArgumentException: The class 'com.example.application.domain.command.CreateTicketCommand' is not in the trusted packages: [java.util, java.lang]. If you believe this class is safe to deserialize, please provide its name. If the serialization is only done by a trusted source, you can also enable trust all (*).
источник

S🕶

Sander 🕶 in pro.kafka
есть конфиги -
KafkaConsumerConfig
KafkaProducerConfig
KafkaTopicConfig
,

что я могу предоставить?
источник

S🕶

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

S🕶

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

λ

λλ in pro.kafka
Sander 🕶
моя проблема всем понятна, сижу над проблемой больше суток -не могу заставить работать, требуется помощь(
тебе нужен канал по спрингу а не по кафке либо сходи в гиттер спроси про кафка спринг или че там у тебя
источник

S🕶

Sander 🕶 in pro.kafka
я уже где только не спрашивал - меня в этот чат и направили за помощью
источник

S🕶

Sander 🕶 in pro.kafka
и в канале по спрингу спрашивал, там тишина
источник

S🕶

Sander 🕶 in pro.kafka
уже устал пытаться настроить Kafka,
источник

λ

λλ in pro.kafka
Sander 🕶
и в канале по спрингу спрашивал, там тишина
кафка тут не причем
источник

λ

λλ in pro.kafka
у тебя спринг
источник

λ

λλ in pro.kafka
источник

VG

Vik Gamov in pro.kafka
Sander 🕶
props.put(JsonDeserializer.TRUSTED_PACKAGES, "*"); - добавил эту строку ошибка не поменялась,
org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition create-ticket-0 at offset 63. If needed, please seek past the record to continue consumption.
Caused by: java.lang.IllegalArgumentException: The class 'com.example.application.domain.command.CreateTicketCommand' is not in the trusted packages: [java.util, java.lang]. If you believe this class is safe to deserialize, please provide its name. If the serialization is only done by a trusted source, you can also enable trust all (*).
Trusted packages надо настраивать на стороне Спринга
источник

S🕶

Sander 🕶 in pro.kafka
Vik Gamov
Trusted packages надо настраивать на стороне Спринга
так я и пытаюсь это сделать, все перепробовал - весь интернет облазил,
источник

S🕶

Sander 🕶 in pro.kafka
Vik Gamov
Trusted packages надо настраивать на стороне Спринга
оно работает только в 1-одном случаи
источник

S🕶

Sander 🕶 in pro.kafka
если я добавлю вот это containerFactory = "${container.factory.create-ticket}"
источник

VG

Vik Gamov in pro.kafka
Sander 🕶
так я и пытаюсь это сделать, все перепробовал - весь интернет облазил,
ну вы кладыаац проект куданить. Надо смотреть
источник

S🕶

Sander 🕶 in pro.kafka
@Bean
public ConcurrentKafkaListenerContainerFactory<String, CreateTicketCommand> createTicketListenerContainerFactory() {
ConcurrentKafkaListenerContainerFactory<String, CreateTicketCommand> factory = new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(genericConsumerFactory(CreateTicketCommand));
return factory;
}
источник