ConsumerRecord returns 空值

Question

刚开始学习apache kafka，正在尝试创建一个POS的示例应用项目。在这个项目中，我遇到了 ConsumerRecord 对象的问题。该对象为我提供了对应于 value 属性的空值，我期望 PosInvoice.class.

类型的对象

代码库位于以下位置：- https://github.com/romitmodi/pos-simulator/blob/master/src/main/java/learning/kafka/tutorial/pos/simulator/InvoiceConsumer.java

不确定我做错了什么。请有人指教。

非常感谢。

Answer 1

您在 learning/kafka/tutorial/pos/simulator/deserializers/JsonDeserializer 的第 31 行缺少“return”语句。java