Kafka Listener 问题给出空值

问题描述 投票:0回答:0

我的 kafka 接收器监听器类中有以下代码

@EnableKafka
@Service
@Component
@Slf4j
public class MessageListener{
@Autowired
@Qualifier("MessageBeanService")
@KafkaListenter(topic={"test-topic}, autoStartup="true" groupId="test-consumer-group")
@Transactional(propagation=Propagation.REQUIRES_NEW)
public void receiveMessage(@Payload String message) throws JsonProcessingException
ObjectMapper objMapper=new ObjectMapper;
objMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, FALSE);
CartSt msg=objMapper.readValue(messages, CartSt.class)

CartSt 有 Item、Price、Quantity 等子对象。 但我看到那些子对象被填充为空值。 ObjectMapper 来自fasterxml.jackson.databind jar 包。 如何解决这些问题并为子对象项填充正确的非空值。 CartSt 主要对象的价格、数量。 请指教

java apache-kafka jaxb listener jackson-databind
© www.soinside.com 2019 - 2024. All rights reserved.