我有使用spring.cloud.stream.kafka.binder.brokers=KAFKA_URL spring.cloud.stream.kafka.binder.zkNodes=ZKNODE_URL的消费者
如果我尝试运行spring boot消费者应用程序，但bean未启动，则整个spring boot应用程序无法启动</
浏览 4提问于2017-03-21得票数 0
我看到一些人将@EnableKafka添加到他们的spring boot应用程序中，我想知道为什么。我有一个可以正常工作的spring boot kafka生产者和消费者，我没有使用@EnableKafka。那么，为什么人们需要明确地添加它呢？ 谢谢。
浏览 181提问于2020-04-17得票数 16
回答已采纳
我有一个Spring Boot应用程序，其中有一个Kafka消费者和生产者。还有一个用于创建主题的bean。我的Spring Boot应用程序和Kafka都是在Kubernetes的Docker中启动的。有时Spring Boot应用程序在Kafka pod启动之前启动，因此无法启动，因为消费
浏览 149提问于2020-09-24得票数 0
回答已采纳
我的应用程序使用嵌入了tomcat的spring boot和webflux。 </dependency> <gr
浏览 9提问于2021-06-09得票数 0
我有一个应用程序，它使用2.10.0版本中的SpringBoot 2.10.0 version和kafka。这个应用程序有一个简单的生产者和消费者:发送者使用KafkaTemplate，消费者使用KafkaListener。我试图实现的目标是即使KafkaServer没有运行，也能够启动SpringBoot应用程序。目前，如果没有正在运行的KafkaBroker，应用程序将无法启动，并显示以下错误消息： org.springframework.cont
浏览 216提问于2019-01-25得票数 2
1回答
我们正在使用spring boot 2.1.7.RELEASE和spring-kafka 2.2.7.RELEASE。现在，我们计划将spring-kafka版本更新到2.4.0.RELEASE并在应用程序启动时获取以下错误
java.lang.ClassNotFoundException: org.springframework.core.log.LogAccessor
浏览 60提问于2020-02-19得票数 0
回答已采纳
2回答
我有一个使用Spring Boot框架构建的Spring Rest应用程序。现在，在编写Spring Integration Test时，我想要将一个类从get component scanned.my中排除。这个类包含Apache Kafka的依赖项。如果这个类在容器启动时加载，它就会开始寻找Kafka运行的实例。
因此，在运行集成测试时，我不会启动我的Kafka服务器，所以我想运行集成测试，使Kafka<
浏览 3提问于2017-02-15得票数 1
1回答
我们有一个spring引导服务，它总是在启动时得到这个错误： at org.springframework.kafka.core.KafkaAdmin.addTopicsIfNeeded(KafkaAdmin.java:221)
浏览 10提问于2022-03-03得票数 1
回答已采纳
我正在开发一个Spring Boot应用程序，它使用以Kafka主题为源的Spring集成流。这些配置为通过云配置和spring.cloud.stream.kafka.bindings从Kafka读取。
当应用程序第一次启动时，它会立即开始读取Kafka主题。这是一个问题，因为应用程序需要初始化一些本地的、不可持久的数据库，然后才能开始正确处理传入的Kafka消息
浏览 0提问于2018-04-24得票数 1
我正在使用Kafka设置一个基本的Spring Cloud Stream producer。其目的是接受HTTP POST，使用Spring Data JPA将post的结果保存到数据库，并使用Spring Cloud Stream Kafka Binder将结果写入Kafka主题。我正在学习如何设置KafkaTransactionManager的最新活页夹documentation，但此代码在应用程序启动时导致错误。──┐
| kafkaTrans
浏览 25提问于2021-07-01得票数 0
回答已采纳
我有一个使用kafka streams的spring boot应用程序(kafka docker镜像：wurstmeister/kafka:2.12-2.1.1，kafka依赖：org.apache.kafka在应用程序启动期间，我检查是否创建了主题my-topic，如果没有- application创建了它。当新版本的应用程序准备就绪时，k8s会启动新
浏览 1提问于2020-05-22得票数 0
1回答
Kafka未连接到下面的问题
、、、、
=localhost:9092spring.kafka.consumer.auto-offset-reset=earliestspring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consume
浏览 7提问于2021-09-09得票数 1
有一个遗留应用程序，它使用JUL并通过代码注册处理程序。现在，我在遗留应用程序中使用了springboot。我尝试使用最小的spring启动依赖项，它只包含spring- boot -starter，不包括spring-boot-starter-logging；在application.properties中将org.springframework.boot.logging.LoggingSystem设置为none；使用commons
浏览 49提问于2019-09-11得票数 0
我有一个应用程序是基于spring boot，spring-kafka和kafka-streams。当应用程序启动时，它使用默认的主题列表创建kafka streams拓扑。例如，当应用程序已经运行时，有一个新的主题名称出现，我想将此主题添加到我的拓扑中。目前我正在考虑以某种方式删除现有的拓扑，关闭并清理KafkaStreams，运行逻辑，我创建拓扑，但使用新的主题名称，并再次启动KafkaStre
浏览 16提问于2020-04-11得票数 1
回答已采纳
我们目前正在尝试创建一个SCS应用程序，该应用程序可以生成特定的主题消息，但是在运行该应用程序时，我们遇到了错误： The following method did not exist:
org.springframework.kafka.core.DefaultKafkaProducerFactory.setBeanName我们认为spring-boot和SCS之间存在兼容性问题。我们使用的是spring-boot版本: 2.2.2-REL
浏览 109提问于2020-07-22得票数 1
回答已采纳
我寻找在spring boot编译后动态加载jar，例如我会将jar放在某个文件夹中，当spring boot启动时，该文件夹中的所有jar都将被注入到spring boot应用程序中。我不知道如何使用spring boot来做到这一点，如果你知道，可以用一些例子来帮助我。我需要这个罐子有@Service，@Controller，因为这将是模块(插件)，并将功能添加到我的spring</em
浏览 6提问于2014-09-10得票数 3
1回答
我必须创建一个kafka消费者作为我的应用程序的一部分。但由于用例的原因，我必须手动轮询。因为每当投票没有从主题返回任何消息时，我都必须采取某些步骤。我不能使用spring kafka做到这一点，因为它只在收到消息时调用。 有没有办法在应用程序启动时运行这个使用者？我正在考虑使用CommandLineRunner，但它似乎不干净(Are there any problems with this way of starting an infinite loop in a Sprin
浏览 13提问于2020-03-28得票数 1
最重要的是，“汽车”前缀背后的原因是什么？用@Configuration而不是@AutoConfiguration注解的类不那么自动或什么的？
浏览 19提问于2022-10-18得票数 1
回答已采纳
我已经建立了一个Camunda BPM与Spring Boot作为一个独立的流程引擎，它将等待从其他web应用程序启动流程的一些请求谢谢
浏览 6提问于2015-11-19得票数 4
在spring-boot (版本2.1.4)应用程序中，需要将apache-kafka迁移到spring-kafka。当前的kafka使用者做: 1)在应用程序启动时初始化的apache 2)它有"0“主题分区集3)使用KafkaConsumer kafkaConsumer将数据轮询到ConsumerRecord 4)应用程序自己的重试机制等待并再次轮询直到max_retry 遗留代码如下所示： whil
浏览 21提问于2019-04-15得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
