我想在CLI模式下创建一个Quarkus应用程序，以便从kafka获取数据并将其批量存储在数据库中(作为穷人的Spark)。有没有可能以某种方式注入一个Kafka消费者，并手动决定(根据offset lag)获取消息？ Thnx
浏览 14提问于2021-01-11得票数 0
我正在尝试在quarkus:dev模式下运行一些kafka测试。
问题是quarkus:dev模式测试运行器不能启动redpanda kafka容器。这是一个已知的问题，还是目前不可能做到？
浏览 3提问于2021-07-09得票数 0
我想知道，有没有办法使用eclipse中的quarkus框架来调试我的camel路由呢？
浏览 4提问于2021-09-17得票数 0
我刚刚创建了一个示例Quarkus CLI应用程序。当我在dev模式下运行它时，按enter键不会重新启动应用程序。重现步骤： 我在macOS Big Sur上使用quarkus，这是默认的终端应用程序。我使用以下命令生成一个默认的cli应用程序： quarkus create cli --group-id=test --artifact-id=test --maven --java --code 然后，一旦我进入t
浏览 50提问于2021-07-10得票数 0
回答已采纳
我尝试了一个简单的示例代码来测试从Quarkus 2.2.2使用smallrye-reactive-messaging-kafka对"kerberized“Kafka的访问： package org.acme: " + record.value() ) ;
} Kafkas是Kerberos的幕后推手，所以我使用了这样的application.properties： quarkus.ssl.nativemp.messa
浏览 59提问于2021-09-10得票数 1
1回答
在开发过程中，我运行了kafka和动物园管理员从一个码头-撰写，然后运行我的夸克服务在开发模式下：在这一点上，一切正常。我尝试了几个不同的秘密在我的码头写作，但没有一个工作。它只是无法连接到经纪人。这是我的Dockerfile：# This Dockerfile is used in order to build a container that runs the Quarkus appl
浏览 0提问于2021-08-05得票数 0
回答已采纳
我有一个Quarkus Kafka消费者。在VM模式下，它工作得很好。 在我使用./mvnw包-Pnative构建本机运行器之后 当我在本机模式下运行它时，我有这样的异常： 2019-05-23 17:17:42,340 ERROR [io.sma.rea.mes.imp.LegacyConfiguredStreamFactory<init>(KafkaSource.java:35)
at io.smallrye.reactive.
浏览 37提问于2019-05-23得票数 2
1回答
我有一个非常简单的Quarkus微服务，它使用smallrye reactive messaging (kafka)。有时我的kafka经纪人宕机了，我得到了以下日志： 2020-09-24 04:04:27,067 WARN [org.apa.kaf.cli.NetworkClient] (kafka-producer-network-threadbroker xxxxxxx.xxxx.xxx:2202 (id: -1 rack: null) disconnected
浏览 36提问于2020-09-27得票数 1
-173-泛型”，arch："amd64"，系列："unix“
mvn clean install failsafe:verify -DCI=true -Dhono.components.type=quarkus-Dhono.deviceregistry.type=mongodb -Dhono.messaging-infra.type=kafka -Dhono.commandrouting.cache=server-Dorg.slf4j.simpleLogger.log.org.apache.maven.cli</em
浏览 13提问于2022-03-30得票数 0
回答已采纳
2回答
我正在尝试了解更多关于kafka streams和quarkus的信息，并且我正在尝试部署来自github https://github.com/kgshukla/data-streaming-kafka-quarkus的样例流应用程序。' for io.quarkus:quarkus-kafka-streams:jar is missing. @ line 55, column 17
浏览 158提问于2021-03-16得票数 0
我正在将Spring应用程序迁移到Quarkus。它是一个应用程序，发布与Avro连载的Kafka消息。Spring版本能够为这些Avro类型生成必要的源代码。Quarkus应用程序失败的原因如下： implementation("io.quarkus:<em
浏览 0提问于2021-12-21得票数 0
将AWS Glue模式注册表与quarkus reactive messaging集成时出现问题。我有一个属性定义为： mp.messaging.outgoing.eligibility.schemaName=<some schema name> 请注意schemaName中的camelcase。Glue schema注册中心正在寻找kafka的值，但从日志输出中，quarkus似乎将该属性放在所有小写的schemaName中，因此添加其他schemanam
浏览 21提问于2021-04-28得票数 0
我在Quarkus2.1.2的基础上创建了一个新的Kafka项目，遵循这两个指南：
没有必要使用特定的Mave
浏览 2提问于2021-08-11得票数 0
我试图使用Quarkus插件构建一个具有所有依赖项(runnable)的uberJar。使用maven，您可以通过向插件添加一个配置来构建它。这就是在maven中的样子： <groupId>io.quarkus</groupId> <version>${quarkus</em
浏览 4提问于2019-03-29得票数 0
回答已采纳
1回答
当我建立一个本土形象的时候，我正面临着一个反思的问题。:该元素的声明类已被替换，但替换类中不存在此元素
我的水壶
<?xml version="1.0" encoding="UTF-8"?<artifactId>quarkus-smallrye-reactive-messaging-kafka</artifactId>
浏览 7提问于2020-04-03得票数 1
1回答
卡夫卡消费者没有消费
、、、
我正在尝试创建一个带有10个分区的Kafka主题的应用程序。我没有在application.properties中定义消费者的分区数，因为应用程序将部署在OpenShift中，我希望OpenShift完成负载平衡。Payload com nrProtocolo '" + payload.getNrProtocolo() + "' consumido com sucesso.");作为反序列化器，它的日志没有显示任何内容e) {
浏览 6提问于2022-10-11得票数 1
回答已采纳
我把期末成绩提高到2.14.1，问题的第一个版本是2.13.3，最后也是2.13.4。[INFO] --- quarkus-maven-plugin:2.14.1.Final:dev (default-cli3-将第一步生成
浏览 13提问于2022-11-21得票数 0
回答已采纳
写了一个使用smallrye- kafka -messaging阅读kafka主题的程序。现在，我需要group.id属性在服务运行/重新启动时是随机的，因此我在quarkus项目中使用了该属性 mp.messaging.incoming.incoming_topic_name.group.id=${quarkus.uuid} 在application.properties中生成随机uuid的quarkus指南中提到了${quarku
浏览 60提问于2021-09-20得票数 1
回答已采纳
我试图用jar文件来附加javaagent，在jar文件中，我在Quarkus中实现了一个简单的Kafka使用者。我计划在以下命令的帮助下，将使用者指标推送到指定的端口。/quarkus-run.jarError: Could not find or load main class io.quarkus.bootstrap.runner.QuarkusEntryPointCaused by: java.lang.Class
浏览 15提问于2022-03-09得票数 0
我想使用这个扩展: Quarkus Smallrye Reactive Messaging Kafka@ApplicationScoped
public class PriceGener
浏览 20提问于2021-02-18得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
