Spring Kafka信任包

pn9klfpd  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(220)

我有不同的对象,我想发送和接收,他们在不同的包。
object1->com.foo.bar.model
object2->com.foo.xyz.model
以下是消费者工厂:

public ConsumerFactory<String, Object> consumerFactory() {
    Map<String, Object> props = new HashMap<String, Object>();
    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, address);
    JsonDeserializer<Object> deserializer = new JsonDeserializer<Object>(Object.class);
    deserializer.addTrustedPackages("com.foo.bar.model","com.foo.xyz.model");
    return new DefaultKafkaConsumerFactory<String, Object>(props, new StringDeserializer(), 
    deserializer);

}

我想做下面这样的事情,这样我就不必添加更多的软件包,但它不工作。
反序列化程序.addtrustedpackages(“com.foo”);

deserializer.addtrustedpackages(“com.foo.**”);
如何在不编写太多代码的情况下实现上述功能。
p、 请不要建议反序列化程序。addtrustedpackages(“*”);
或者在application.properties中写入任何内容

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题