草庐IT

KafkaAvroDeserializer

全部标签

java - KafkaAvroDeserializer 不返回 SpecificRecord 但返回 GenericRecord

我的KafkaProducer能够使用KafkaAvroSerializer将对象序列化到我的主题。但是,KafkaConsumer.poll()返回反序列化的GenericRecord而不是我的序列化类。MyKafkaProducerKafkaProducerproducer;try(InputStreamprops=Resources.getResource("producer.props").openStream()){Propertiesproperties=newProperties();properties.load(props);properties.put(Produc