AVRO生成了pojo的Kafka Spring云模式注册表
我正在考虑使用模式来验证Kafka主题的数据。我正在结合apache kafka探索spring云模式注册表。
如果我在阅读文档后理解正确。Spring云模式注册表仅支持avro模式！在avro pojos中，需要使用类路径上的. avsc文件生成pojos，并且有一个maven插件可以完成所需的工作。
问题：
如果我的POJO上有这样的自定义验证呢？我不想在我的Kafka消费者中使用avro模式生成这个pojo，因为我失去了验证。有没有人遇到过类似的问题？如果是，您是如何解决的？
public class Pojo implements Serializable {
@Color
private String colour;
.....
@Target({ElementType.FIELD, ElementType.PARAMETER, ElementType.TYPE_USE})
@Retention(RetentionPolicy.RUNTIME)
@Constraint(validatedBy = ColorValidator.class)
public @interface Color {
.....
public class ColorValidator implements ConstraintValidator<Color, String> {
......
共有1个答案
如果我的POJO上有自定义验证怎么办
如果您从模式文件生成POJO，您仍然可以定义ConstraintValidator实现。
换句话说，您创建AVSC，并使用avro maven插件创建类（mvn compile），然后类路径将具有可用于定义约束验证器的类。
不过，您可能需要查看CustomEncoding类来实际验证Avro对象。
-
我已经设置了Spring Cloud Stream中提供的Spring Avro模式注册表，以便在RabbitMQ中使用。我看到的大多数示例都使用Maven Avro插件从模式资源文件生成Java类。然后在架构注册表中注册架构文件。我的理解是，此注册表允许消息仅通过对已注册架构的引用进行SERDE，而不是在消息中包含整个架构。我不明白的是，在设计时，这些模式文件是如何在所有服务之间分发的，以生成J
-
我现在一直在查看Spring Cloud模式注册表和汇合模式注册表。我可以看到一些区别，例如Spring Cloud模式注册表将模式保存在普通数据库中，默认情况下保存在h2中，而汇合模式注册表保存在kafka主题中。 spring云模式注册表的这种方法是否会对性能产生任何影响。据我所知，即使数据保留在主题上，以防汇合，查询它时仍然会有延迟。但会有重大影响吗？ 我还可以看到，spring云模式注册表
-
我正在尝试使用以下方法在运行时获取Avro模式： 但由于我的POJO类包含以下泛型： 我得到以下例外情况： 我知道Avro不会支持泛型类型。是否有一种方法可以在运行时生成架构时从类中省略某些类字段？
-
我正在尝试使用Confluent schema registry，下面是我在Github中找到的一些示例(https://github.com/gAmUssA/springboot-kafka-avro). 当消费者和生产者与模型共享相同的命名空间而不是其工作时。 当使用者位于具有不同名称空间但具有相同类（名称和属性方面）的不同项目中时，它不工作。 合流Avro反序列化程序可以使用正确的值反序列化
-
我有一个Kafka消费者配置了主题中的模式轮询，我想做的是在当前模式的基础上创建另一个Avro模式，并使用它水合数据，基本上我不需要50%的信息，需要编写一些逻辑来更改几个字段。这只是一个例子 从stream返回的事件相当复杂，所以我将一个较小的CustomObj建模为. avsc文件，并将其编译成java。当尝试使用CustomObj运行代码时，我想做的就是使用一个事件，然后将其反序列化为一个更
-
假设我生成了一个具有多个属性的域对象。我想为defn类中的一个对象属性生成@jsonignore注释。