写了一个使用smallrye- kafka -messaging阅读kafka主题的程序。=${quarkus.uuid} 在application.properties中生成随机uuid的quarkus指南中提到了${quarkus.uuid} 但是，当在应用程序中使用此属性时，会出现此异常(ExpressionConfigSourceInterceptor.java:18) 还尝试了-删除了group.id属性，以便kafka使用quark
浏览 60提问于2021-09-20得票数 1
回答已采纳
如何使用quarkus + kafka + smallrye处理流处理异常？我的代码与quarkus guide (https://quarkus.io/guides/kafka#imperative-usage)上的命令式生成器示例非常相似 import io.smallrye.reactive.messaging.annotations.Channel;
import io
浏览 20提问于2020-01-31得票数 4
我有一个Quarkus Kafka消费者。在VM模式下，它工作得很好。 在我使用./mvnw包-Pnative构建本机运行器之后 当我在本机模式下运行它时，我有这样的异常： 2019-05-23 17:17:42,340 ERROR [io.sma.rea.mes.imp.LegacyConfiguredStreamFactoryat io.smallrye.reactive.messaging.kafka.KafkaSource.<init>(KafkaSource.java:35
浏览 37提问于2019-05-23得票数 2
我尝试了一个简单的示例代码来测试从Quarkus 2.2.2使用smallrye-reactive-messaging-kafka对"kerberized“Kafka的访问： package org.acmelocation>mp.messaging.incoming.in.connector=smallrye-kafka<init&
浏览 59提问于2021-09-10得票数 1
我尝试构建Quarkus kafka消费者应用程序，该应用程序必须反序列化kafka topic.when中可用的avro序列化器消息。我尝试按如下方式配置架构注册表(Confluent`s)，以使用avro反序列化kafka消息，最终出现异常schema.registry.url=http://kafka-exposed:8081(KafkaConsumer.java:168)
82 at io.smallrye.reactive.me
浏览 3提问于2019-10-28得票数 2
我想分批处理。在我的用例中，发送卡夫卡生产者消息是一个接一个。我想将它们作为消费者应用程序中的列表来阅读。我可以在春天卡夫卡图书馆这么做。有什么方法可以用quarkus-smallrye-reactive-messaging-kafka库来做到这一点吗？
我尝试了下面的例子，但得到了一个错误。@6f2c0754; io.smallrye.mutiny.Multi is in unnamed module of loader io.quarkus.bootstrap.classloadin
浏览 3提问于2021-01-19得票数 2
回答已采纳
目前，Quarkus指南指出，为了在与Kafka代理通信时启用SSL，您应该设置 quarkus.kafka-streams.security.protocol=SSL 但是，这样做会导致以下错误：io.smallrye.config.ConfigValidationException: Configuration validation failed:
quarkus.kafka-streams.security.protocol
浏览 51提问于2021-09-11得票数 0
当我需要通过docker-compose运行它时，我无法更改Kafka主机和端口。我想使用相同的docker-compose来运行我的服务和Kafka。所以我需要更换Kafka主机。我尝试提供以下环境变量，但没有成功: mp.messaging.outgoing.my-channel.bootstrap.servers="Kafka:9092“
我在Quarkus/Kafka指南中使用了相同的
浏览 28提问于2019-10-22得票数 0
回答已采纳
我遵循下面的指南，在没有kafka代理的情况下进行测试。(InMemoryConnector.java:172) at io.quarkus.test.junit.QuarkusTestExtension.interceptTestMethodat com.intellij.rt.junit.JUnit
浏览 13提问于2021-01-25得票数 0
1回答
我有一个夸克应用程序，它使用quarkus-smallrye-reactive-messaging-kafka扩展。在运行时，它生成大量的调试日志：
rent-orchestrator-service | 16:44:11.508 [smallrye-kafka-consumer-thread-0] DEBUG| 16:44:11.508 [smallrye-kafka-consumer-thread-0] DEBUG org.apache.kafka</
浏览 11提问于2022-02-12得票数 0
1回答
卡夫卡消费者没有消费
、、、
e) { return null; }quarkus.kafka.devservices.enabled=falsemp.messaging.incoming.plac-fate.connector=smallrye-kafka18:53:42
浏览 6提问于2022-10-11得票数 1
回答已采纳
我正在使用Quarkus，我正在尝试创建摄取服务，它将数据发送到kafka或其他REST端点。我已经在项目中添加了"quarkus-smallrye-reactive-messaging-kafka“和"quarkus-reactive-messaging-http”依赖项。我可以通过添加两个依赖项和配置来实现这一点，如下所示mp.messaging.outgoing.messages.connector=
浏览 12提问于2021-02-25得票数 1
我只能找到使用Smallrye中的@Ingoing和@Outgoing的例子，但是我不需要一个KafkaStream。我通过命令行从主题中消费，Kafka
浏览 1提问于2019-05-20得票数 0
回答已采纳
1回答
</groupId> </dependency><artifactId>quarkus-smallrye-reactive-messaging-kafka</artifactId>
浏览 7提问于2020-04-03得票数 1
完整的stackTrace：
$ java -jar target/quarkus app/quarkus run.jar线程中的异常(在java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0.上的异常io.quarkus.bootstrap.runner.QuarkusEntryPoint.main(QuarkusEntryPoint.java:28)的doRun(QuarkusEntryPoint.j
浏览 45提问于2022-02-14得票数 0
我正在将Spring应用程序迁移到Quarkus。它是一个应用程序，发布与Avro连载的Kafka消息。:quarkus-resteasy-reactive-jackson")
implementation("io.quarkus:quarkus-smallrye-opentracing")implementation("io.quarkus:quarkus-rest-client-reactive&qu
浏览 0提问于2021-12-21得票数 0
因此，我使用Quarkus以及Microprofile Reactive Messaging框架(带有SmallRye Kafka连接器)和RxJava2 Flowable streams对象来接收/但是，现在我想修改它，这样我仍然可以从Kafka主题中提取内容，并将JSON有效负载发送到REST端点。据我所知，没有Quarkus HTTP兼容的SmallRye连接器。
浏览 40提问于2020-06-19得票数 1
根据故障中的文档-策略=忽略如下(忽略:故障被记录，但处理仍在继续。未正确处理的记录的偏移量已提交。)--- at io.quarkus.arc.runtime.devconsole.InvocationInterceptor.monitor)
浏览 11提问于2022-09-30得票数 0
回答已采纳
属性文件项更改为处理器应用程序无法从以下异常开始:：如何处理夸克中的此类名称$new$0(ConnectorConfig.ja
浏览 8提问于2022-05-06得票数 0
我想使用这个扩展: Quarkus Smallrye Reactive Messaging Kafka@ApplicationScoped }
或者，这些配置应该在运行时以编程方式设置
mp.messagi
浏览 20提问于2021-02-18得票数 2
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
