Spring/Avro-使用融合模式注册表

Question

我正在尝试使用Confluent schema registry，下面是我在Github中找到的一些示例(https://github.com/gAmUssA/springboot-kafka-avro).

当消费者和生产者与模型共享相同的命名空间而不是其工作时。

当使用者位于具有不同名称空间但具有相同类（名称和属性方面）的不同项目中时，它不工作。

合流Avro反序列化程序可以使用正确的值反序列化为GenericData$Record类，但它无法将其强制转换为实际对象。

我正在尝试：

@Data
@AllArgsConstructor
public class User {
    String name;
    int age;
}
...

@KafkaListener(topics = "users", groupId = "group_id")
public void consume(ConsumerRecord<String, User> record) {
    log.info(String.format("Consumed message -> %s", record.value().getName()));
}

上述代码在铸造问题上失败。

当我添加特定时。阿夫罗。reader=忠实于道具，但它也失败了。

这难道不是模式注册中心的全部目的吗？它是一个中心repo，因此数据可以由不同项目甚至不同语言（python、java、net等）中的模式反序列化？

我错过了什么？

Answer 1

问题是您的用户类不是Avro类。

您应该使用Avro-Maven/Gradle插件来生成类，而不是使用Lombok，并且名称空间和完整模式确实需要对齐。我发现最好的管理方法是完全独立于实际的Kafka代码开发和发布模型