ConsumerRecord returns Null value



我刚开始学习apache kafka,并试图创建一个POS的示例应用程序项目。在这个项目中,我面临着ConsumerRecord对象的问题。这个对象为我提供了与value属性相对应的null值,我期望的是PosInvoice.class.类型的对象

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

不确定我做错了什么。请有人给我建议。

提前谢谢。

您缺少"返回";learning/kafka/tutorial/pos/simulator/destrializers/JsonDeserializer.java 第31行的声明

最新更新