我有不同的对象,我想发送和接收,他们在不同的包。
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中写入任何内容
暂无答案!
目前还没有任何答案,快来回答吧!