#apache-kafka #kafka-consumer-api
#apache-kafka #kafka-consumer-api
Вопрос:
Я начал заново изучать apache kafka и пытаюсь создать примерный проект приложения POS. В этом проекте я столкнулся с проблемой с объектом ConsumerRecord. этот объект предоставляет мне нулевое значение, соответствующее атрибуту value, где я ожидаю объект типа PosInvoice.class .
кодовая база находится ниже location:-https://github.com/romitmodi/pos-simulator/blob/master/src/main/java/learning/kafka/tutorial/pos/simulator/InvoiceConsumer.java
Не уверен, что я делаю неправильно. пожалуйста, может кто-нибудь посоветовать.
Заранее большое спасибо.
Ответ №1:
Вам не хватает инструкции «return» в строке № 31 из learning/kafka/tutorial/pos/simulator/deserializers/JsonDeserializer.java