我當前的設(shè)置具有以下配置：@Beanpublic ConcurrentKafkaListenerContainerFactory<String, String> myKafkaListenerContainerFactory(        ConsumerFactory<String, String> consumerFactory) {    ConcurrentKafkaListenerContainerFactory<String, String> factory = new            ConcurrentKafkaListenerContainerFactory<>();    factory.setConsumerFactory(consumerFactory);    factory.setMessageConverter(stringJsonMessageConverter());    return factory;}其中 stringJsonMessageConverter 有@Beanpublic StringJsonMessageConverter stringJsonMessageConverter() {    return new StringJsonMessageConverter(objectMapper());}使用我的對象映射器@Beanpublic ObjectMapper objectMapper() {    return new ObjectMapper()            .registerModule(new JavaTimeModule())            .registerModule(myCustomJacksonModules())            .configure(FAIL_ON_UNKNOWN_PROPERTIES, false)            .configure(ACCEPT_SINGLE_VALUE_AS_ARRAY, true)            .configure(WRITE_DATES_AS_TIMESTAMPS, false);}使用此配置，我可以發(fā)布為：...headers = new MessageHeaders(singletonMap(TOPIC, topic));Foo foo = ....Message<?> message = new GenericMessage<>(foo, headers);kafkaTemplate.send(message);并消費為：@KafkaListener(topics = "myTopic",        groupId = "g1",        containerFactory = "myKafkaListenerContainerFactory")public void onMessageReceived(Foo foo) {    ... works with foo here}如果 Foo 是具體類，這在本例中工作正常。但是，如果 Foo 是抽象的，并且作為消息發(fā)送的是它的子類F1 extends Foo; F2 extends Foo ...... // publisherheaders = new MessageHeaders(singletonMap(TOPIC, topic));F1 f1 = ....Message<?> message = new GenericMessage<>(f1, headers);kafkaTemplate.send(message);... // Listener@KafkaListener(topics = "myTopic",        groupId = "g1",        containerFactory = "myKafkaListenerContainerFactory")public void onMessageReceived(Foo foo) {    ... wont work}在我的消費者中將 Foo 聲明為類型會失敗，但這會起作用：@KafkaListener(topics = "myTopic",        groupId = "g1",        containerFactory = "myKafkaListenerContainerFactory")public void onMessageReceived(Map<String,Object> fooAsMap) {    ... this works too}有沒有辦法在我發(fā)送消息時指定目標類型？