如何使用avro作为消息键和值在quarkus中使用和测试kafka

w1jd8yoj  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(234)

我正在尝试使用[kafka quarkus][1]从一个主题中读取一些事件,并将一些事件写入另一个主题。
主题中的所有消息都是avro格式(key和value)。
上面报告的文档没有显示如何使用 @Incoming 以及 @Outgoing 当消息是avro格式时的注解。
在互联网上搜索我发现了一个[blog][2],其中展示了如何将quarkus与kafka、avro和schema registry一起使用。
所有报告的示例都不适合我的情况,我有一个消息(aka record),其中的键值都是avro格式的。
有没有一种方法可以使用kafka-quarkus集成来读取和生成关于avro主题的消息,并实现一些测试[1]: https://quarkus.io/guides/kafka [2]: https://quarkus.io/blog/kafka-avro/

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题