如何使用Spring Cloud Stream使用Confluent Schema Registry生成和使用Avro消息？
我可以通过跟随Kafka和Spring Cloud的Start Streaming来运行示例，但不幸的是，它没有使用confluent schema Registry。我阅读了Spring Cloud Stream reference guide的confluent schema registry部分，但它不适用于我的confluent 3.0.0，而且该指南没有提到如何使用confluent schema registry生成Avro消息。那么，有人能指导我如何实现吗？谢了！
共有1个答案
Spring Cloud Stream与Confluent Schema Registry尚不兼容。请参阅本线程https://github.com/spring-cloud/spring-cloud-stream/issues/850中的讨论
-
pom.xml： 我已将以下架构发布到注册表： 原始测试应用程序。yml 发件人类编辑： 由于不适当使用导致原始Stacktrace/Exception 我在这里回顾了几个不同的帖子，但似乎没有什么帮助。我可能错过了什么？ Spring Boot：配置类被忽略，不加载 现在正在使用。我可以在调试时单步执行代码，但它没有找到模式。 Register（字符串主题、字符串格式、字符串模式）
-
使用StreamBridge，我将包含两种不同类型的对象的消息发送到单个Kafka主题。有没有办法定义一个能够使用两种类型消息的Spring Cloud Stream的功能消费者？
-
有没有办法从Apache spark生成无模式的avro？我可以看到一种使用apache avro库通过Java/Scala和融合avro生成它的方法。当我用下面的方式从Spark编写Avro时，它用模式创建了Avro。我想在没有模式的情况下创建，以减少最终数据集的大小。
-
我试图使用ConsumerSeeKaware，阅读kafka主题中可用的最后一条消息。消息类型是Avro对象列表。我能成功地做到这一点。但在反序列化过程中会失败。该消息使用spring-cloud-stream-kafka框架生成。消息具有contentType。 我知道avro消息可以像下面这样反序列化。 但不管用。可能是因为两件事。 > 消息是avro对象的列表。但我正在尝试使用Avro模式创
-
我正在使用以下客户端代码创建远程KafkaProducer 一旦我创建了生产者，我就可以运行下面的行并返回有效的主题信息，假设strTopic是一个现有的主题名称。 当我尝试发送消息时，我会执行以下操作：
-
我已经在本地安装了kafka（目前没有集群/模式注册），并尝试生成一个Avro主题，下面是与该主题相关的模式。 我想创建一个简单的来根据上述模式创建一些数据并将其发布到kafka。考虑创建转换为的示例数据，然后将其更改为然后发布。 然后，如下所示： 现在可以< code >手动将模式附加到此avro主题。 这可以通过使用而不是使用来实现吗？这是用于批处理，而不是。