我是新手阿帕奇Kafka，我已经创建了一个简单的Spring启动生产者和消费者项目，可以生产和消费正确的消息，但现在我想与Kafka流工作，但面临着困难找到一个简单的POC的Kafka流与SpringBoot，有人可以与我分享一些简单和易于理解的项目，这将是非常有帮助的。
浏览 60提问于2020-08-15得票数 0
回答已采纳
我正在学习卡夫卡流，我得到了一个错误，我尝试了一些东西，但是注意到了作品public static void main(String[] args) throws InterruptedException { String consumer_group = "firstGroup1";
浏览 16提问于2022-01-08得票数 0
回答已采纳
我在启动和运行我的Kafka / confluent spring boot with gradle项目时遇到了一个问题。我最初在这个测试项目中只有一个生产者，一切都运行得很好。', version: '3.0.0'
compile('org.springframework.boot:spring-boot-starter-data-elasticsearch')compile group: 'org.spr
浏览 506提问于2021-01-23得票数 0
回答已采纳
下面是将第二个流转换为KTable的代码：public KafkaStreams kafkaStreams() throws IOException {
final Propertiesorg.apache.kafka.streams.errors.ProcessorStateException: Error opening store joined-topics at location /var/folders/lx/dz_x9j5d7lz4mfymgzkcn7wr0000gn/T/<
浏览 9提问于2022-09-20得票数 0
使用spring boot创建了spark结构的流媒体应用程序。bootRun运行良好，但在使用"spark-submit“部署相同的jar时，给出了以下错误：com
浏览 1提问于2018-09-23得票数 0
这是关于升级生产中的现有代码库，这些代码库使用来自kafka-clients，kafka-streams，spring-kafka 2.4.0到2.6.x的窗口，并将spring-boot-starter-parent2.2.2.RELEASE升级到2.3.x，因为2.2与kafka-streams 2.6不兼容。KafkaStreams kStream() {return ka
浏览 20提问于2021-05-15得票数 2
我正在尝试做集成测试的应用程序，使用kafka，kafka-streams和cassandra。但是当我尝试setUp测试类时，我得到了两个错误: ERROR main BrokerMetadataCheckpoint:无法读取目录下的meta.properties文件错误main KafkaServer:无法读取日志目录下的meta.properties 我使用了spring-boot-starter 2.1.2、spring-<e
浏览 659提问于2019-01-25得票数 12
我正在开发一个使用kafka streams活页夹的春季云kafka应用。
浏览 1提问于2019-12-10得票数 1
我想使用Kafka Steams和Spring Webflux在Netty之上构建一个流引擎，以通过HTTP提供持续的状态更改。我注意到如果我有在我的gradle文件中，spring boot/m2/" } dependencies {
clas
浏览 8提问于2017-12-25得票数 1
回答已采纳
测试无法用错误的Cannot resolve method 'parse' in 'DockerImageName'编译@Testcontainers implementation 'org.springframework.boot:spring-boot-starter-web'
implementa
浏览 7提问于2020-10-17得票数 1
回答已采纳
我有一个春季引导应用程序，在那里我使用apache streams。我不使用春云流。我添加了执行器健康检查端点。</groupId> </dependency>spring-boot-starter-web</artifactId>
浏览 13提问于2019-09-19得票数 7
回答已采纳
我正在尝试使用spring-cloud-stream，并创建official blog的示例项目。 实现与本文完全相同。现在我的build.gradle是这样的。plugins { id 'io.spring.dependency-management'{
set('s
浏览 34提问于2021-04-12得票数 0
格式我们已经看到了许多关于依赖不匹配的答案，所以我们检查了我们的。我们不能将我们使用的所有poms放在一起，因此下面是相关的依赖项： <groupId>org.springframework.boot</groupId> <version>1
浏览 0提问于2019-06-02得票数 2
我正在做一个POC来演示一些Spring Cloud Kafka功能。我使用的是带有SpringBoot 2.4.1的Java11。我的build.gradle具有以下库 implementation 'org.springframework.cloud'
testImplementation 'org.springfr
浏览 0提问于2021-01-30得票数 0
我有一个应用程序是基于spring boot，spring-kafka和kafka-streams。当应用程序启动时，它使用默认的主题列表创建kafka streams拓扑。我需要做的是在运行时编辑/重新创建拓扑。例如，当应用程序已经运行时，有一个新的主题名称出现，我想将此主题添加到我的拓扑中。目前我正在考虑以某种方式删除现有的拓扑，关闭并清理KafkaStreams，运行逻辑，我创建拓扑，但使用新
浏览 16提问于2020-04-11得票数 1
回答已采纳
需要在Spring绑定器配置中使用KTable，下面是用于从主题读取数据并在控制台上打印数据的示例代码。但是，在应用程序启动时，以抛出java.lang.IllegalArgumentException:方法结束的应用程序必须是声明式。转介，结果仍然一样<parent> <artifactId>sprin
浏览 0提问于2021-03-19得票数 0
我也在我的pom.xml中添加了执行器作为依赖项。<artifactId>spring-boot-starter</artifactId> <dependency> <artifactId>kafka-streams<
浏览 140提问于2018-04-20得票数 2
我正在使用Springboot 2运行Kafka Stream应用程序。我不确定我是否理解kafka流指标是如何导出的。actuator可以获得这些JMX指标吗？有没有办法获得这些指标并以普罗米修斯格式公开它们？PS:也没有使用java jmx_prometheus_agent 有人有解决方案或例子吗？ 谢谢
浏览 46提问于2019-09-25得票数 7
我是IntelliJ (CE 2022.2，MacOS)的新手，过去17年一直是eclipse用户。 <artifactId>spring-boot-starter-parent</artifactId>
<version>2.7.3</version</groupId&
浏览 6提问于2022-08-30得票数 0
在集成开发环境中运行成功 <artifactId>spring-boot-starter-web</artifactId>对于
浏览 0提问于2019-12-12得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号