• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:alpakka

alpakka

在Alpakka中使用KafkaAvroDeserializer

在Alpakka中使用KafkaAvroDeserializer
我有一个SchemaRegistry和KafkaBroker,可以使用Avro v1.8.1从中提取数据。对于反序列化,我一直使用Confluent的KafkaAvroDeserializer。现在,我打算重构代码以使用Alpakka提供的Elasticsearch API,但是不幸的是,这破坏了反序列化,因为它导致NullPointerExceptions……继续阅读 »