如何在SpringBoot应用程序中使用EmbeddedKsql？
我有Kafka Streams java应用程序启动并运行。我试图使用KSQL创建简单的查询，并使用Kafka流来实现复杂的解决方案。我希望将KSQL和Kafka流作为Java应用程序运行。
我打算通过https://github.com/confluentinc/ksql/blob/master/ksqldb-examples/src/main/java/io/confluent/ksql/embedded/embeddedksql.java访问。有没有EmbeddedKsql的文档？或者任何可以工作的原型？
共有1个答案
KSQLDB0.10已经推出，其中最新的特性是Java客户机。
请通过-https://www.confluent.io/blog/ksqldb-0-10-0-latest-features-updates/
-
我是kubernetes的新手，需要在openshift平台上使用k8s confimap将springboot应用程序的属性文件外部化。我已将属性文件保存在git repo中，作为“greeter.message=Spring Bootmyapplication.properties已在库伯内特斯上挂载为卷！”并使用“oc create confimap myconfig--from-file=
-
要获取请求URL，可以在堆栈溢出中找到以下方法。 第一种方法： 第二种方法： 第三种方法： 我不知道在spring boot应用程序中使用哪一个来获取请求URL。 如果我使用第三种方法，那么我是否需要在配置类中创建RequestContextListener的bean，如下所示？
-
我已经为Postgresql启用了复制，并且正在使用PGPool进行负载平衡。 我在使用HikariCP甚至Apache DBCP连接到Postgres时遇到了问题。 在SpringBoot应用程序中有没有使用PGPool的方法？ 请查找堆栈跟踪： 2018-08-10 10:20:19.124信息37879----[main]com.zaxxer.hikari.hikaridatasource：
-
我试图在SpringMVC中运行SpringBoot应用程序，在SpringMVCPOM中添加SpringBoot应用程序依赖项，并扫描SpringBoot包，但我面临以下问题
-
我想在intellij Idea中以调试模式启动spring-boot maven应用程序，但当我创建断点时，应用程序不会挂起，而是会继续。我读了很多题目，但还是不明白怎么做。你能帮我决定最好的行动方案吗。 但是当请求LocalHost:5005/MyPage时，我会出现错误101(NET::ERR_CONNECTION_RESET)。似乎有些maven参数没有指定。 下面是我在pom.xml中的
-
我想启用cassandra cqlsession度量。当尝试注册cqlsession度量时，它提供可选的。springboot应用程序中的empty（）。这里我使用的是cassandra datastax java驱动程序4.6。 这是我的代码： 正在引发IllegalArgumentException错误。 当参考卡桑德拉税务局的官方文件时(https://docs.datastax.com/e