问题标签 [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.
avro - 在 Quarkus 中从另一个 Avro 类型引用 Avro 类型失败,“id”字段的类型必须是定义的名称或 {"type": ...} 表达式
我正在将 Spring Boot 应用程序迁移到 Quarkus。它是一个发布使用 Avro 序列化的 Kafka 消息的应用程序。
这些是模式:
id.avsc
事件.avsc
Spring 版本能够为这些 Avro 类型生成必要的源代码。
Quarkus 应用程序失败并显示:
如何在 Quarkus 中引用另一个 Avro 类型?
构建.gradle.kts
logging - 更改 smallrye kafka 消费者扩展的日志级别
我有一个使用quarkus-smallrye-reactive-messaging-kafka
扩展的 quarkus 应用程序。
在运行时它会产生大量的调试日志:
我试图在中设置不同的日志级别,application.properties
但它不起作用:
我该如何解决?
java - 获取Kafka分配的分区
我正在使用 Quarkus Kafka 消费者。我需要知道我的消费者已经被 Kafka 代理分配到了哪些分区。我可以使用的任何监听器,就像 Kafka 客户端提供的监听器一样。否则如何在集群的每个节点中分配特定分区?
问候