问题标签 [quarkus-kafka]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
28 浏览

avro - 在 Quarkus 中从另一个 Avro 类型引用 Avro 类型失败,“id”字段的类型必须是定义的名称或 {"type": ...} 表达式

我正在将 Spring Boot 应用程序迁移到 Quarkus。它是一个发布使用 Avro 序列化的 Kafka 消息的应用程序。

这些是模式:

id.avsc

事件.avsc

Spring 版本能够为这些 Avro 类型生成必要的源代码。

Quarkus 应用程序失败并显示:

如何在 Quarkus 中引用另一个 Avro 类型?

构建.gradle.kts

0 投票
0 回答
22 浏览

logging - 更改 smallrye kafka 消费者扩展的日志级别

我有一个使用quarkus-smallrye-reactive-messaging-kafka扩展的 quarkus 应用程序。

在运行时它会产生大量的调试日志:

我试图在中设置不同的日志级别,application.properties但它不起作用:

我该如何解决?

0 投票
1 回答
16 浏览

java - 获取Kafka分配的分区

我正在使用 Quarkus Kafka 消费者。我需要知道我的消费者已经被 Kafka 代理分配到了哪些分区。我可以使用的任何监听器,就像 Kafka 客户端提供的监听器一样。否则如何在集群的每个节点中分配特定分区?

问候