我正在尝试了解更多关于kafka streams和quarkus的信息,并且我正在尝试部署来自github https://github.com/kgshukla/data-streaming-kafka-quarkus的样例流应用程序。但是,每次我运行quarkus时,我都会收到以下错误。我检查了pom.xml,但我看不出有什么问题。我直接从存储库克隆了示例应用程序,并且没有做任何更改 [INFO] Scanning for projects...
[ERROR] [ERROR] Some problems were encountered while processing the POM
我创建了一个夸克服务,它从一堆Kstreams中读取,加入它们,然后将连接结果发回一个kafka主题。在开发过程中,我运行了kafka和动物园管理员从一个码头-撰写,然后运行我的夸克服务在开发模式下:
mvn quarkus:dev
在这一点上,一切正常。我能够毫无问题地连接到代理,并读取/写入Kstreams。
然后我尝试创建一个码头容器来运行这个夸克服务,但是当服务在容器内运行时,它不会到达代理。我尝试了几个不同的秘密在我的码头写作,但没有一个工作。它只是无法连接到经纪人。
这是我的Dockerfile:
####
# This Dockerfile is used in order to
目前,Quarkus指南指出,为了在与Kafka代理通信时启用SSL,您应该设置 quarkus.kafka-streams.security.protocol=SSL 但是,这样做会导致以下错误: io.smallrye.config.ConfigValidationException: Configuration validation failed:
quarkus.kafka-streams.security.protocol does not map to any root
Spring boot Apache Camel-Java DSL应用程序从Kafka主题读取消息。 @Component
public class KafkaTopicService extends RouteBilder {
public void configure(){
from("kafka:myTopic?brokers=localhost:9092")
.log("Message received from Kafka: ${body}")}
} 如果我阻止卡夫卡我会得到org.apache.kafk
我正在尝试将项目(来自Quarkus的入门资源)构建为带有多阶段Docker构建的容器中的本地可执行文件。构建在“夸夸斯-maven-plugin:0.21.2:原生-映像”阶段出现之前,被塞了很长一段时间。
在解决方案中,我使用Dockerfile run docker-compose up启动Kafka代理,然后添加下一个多阶段Dockerfile:
## Stage 1 : build with maven builder image with native capabilities
FROM quay.io/quarkus/centos-quarkus-maven:19.2.0 AS
我有一个Quarkus Kafka消费者。在VM模式下,它工作得很好。 在我使用./mvnw包-Pnative构建本机运行器之后 当我在本机模式下运行它时,我有这样的异常: 2019-05-23 17:17:42,340 ERROR [io.sma.rea.mes.imp.LegacyConfiguredStreamFactory] (main) Unable to create the publisher or subscriber during initialization: java.lang.IllegalArgumentException: java.lang.reflect.In
我正在关注这个quarkus研讨会:,并得到这个错误
测试容器有一些问题,也许我不能解决。我能够运行带有docker图像的应用程序,但只有测试失败,并出现以下错误。
测试日志:
[INFO] -------------------------------------------------------
[INFO] T E S T S
[INFO] -------------------------------------------------------
[INFO] Running io.quarkus.workshop.superheroes.fight.FightResourceT
我想使用这个扩展: Quarkus Smallrye Reactive Messaging Kafka
但是在我的应用程序中,主题的名称是事先不知道的,它是根据在运行时从用户收到的消息来指定的。如何以编程方式在没有注释的情况下指定与主题相关的主题名称和设置?(仅用于向Kafka -> Produce发送消息)
@ApplicationScoped
public class PriceGenerator {
private Random random = new Random();
// Don't want to use this
// "g
我还创建了独立的应用程序,并成功地执行了程序。
[INFO] --- quarkus-maven-plugin:1.1.1.Final:dev (default-cli) @ monitoring ---
Listening for transport dt_socket at address: 5005
2020-01-08 09:48:30,248 INFO [io.quarkus] (main) monitoring 1.0.0-SNAPSHOT (running on Quarkus 1.1.1.Final) started in 3.090s. Listening on: http
我试图用jar文件来附加javaagent,在jar文件中,我在Quarkus中实现了一个简单的Kafka使用者。我计划在以下命令的帮助下,将使用者指标推送到指定的端口。
java -javaagent:./jmx_prometheus_javaagent-0.16.1.jar=9080:kafkaconsumer.yml -jar ./quarkus-run.jar
我得到以下错误,
Error: Could not find or load main class io.quarkus.bootstrap.runner.QuarkusEntryPoint Caused by: java.la
我正在尝试修复Quarkus应用程序中的以下警告:
2019-11-17 16:21:34,191 INFO [io.qua.dep.QuarkusAugmentor] (main) Beginning quarkus augmentation
2019-11-17 16:21:34,975 WARN [io.qua.dep.ste.ReflectiveHierarchyStep] (build-11) Unable to properly register the hierarchy of the following classes for reflection as they are
我想分批处理。在我的用例中,发送卡夫卡生产者消息是一个接一个。我想将它们作为消费者应用程序中的列表来阅读。我可以在春天卡夫卡图书馆这么做。
有什么方法可以用quarkus-smallrye-reactive-messaging-kafka库来做到这一点吗?
我尝试了下面的例子,但得到了一个错误。
ERROR [io.sma.rea.mes.provider] (vert.x-eventloop-thread-3) SRMSG00200: The method org.MyConsumer#aggregate has thrown an exception: java.lang.ClassCas