我有一个关于数据的卡夫卡主题，叫做"topic01“ latch.countDown();application.properties：
spring.kafka.con
浏览 11提问于2020-05-20得票数 0
回答已采纳
我的要求是，当应用程序无法处理从通过spring boot java应用程序使用的kafka主题的当前偏移量读取的消息时，重置kafka主题的偏移量。在手动重置偏移量或发送否定确认之后，需要通过spring boot java应用程序的kafka消费者再次从不合适的偏移量值轮询消息。它能实现吗？
浏览 3提问于2019-01-09得票数 1
我的spring boot应用程序使用的是aws kinesis绑定器，它充当消费者。我将最后一个序列号保存在数据库中，以便在应用程序重启时读取该序列号，并使用AFTER_SEQUENCE_NUMBER作为shardIteratorType在该序列号之后开始处理。
浏览 23提问于2020-10-01得票数 0
我正在尝试使用Spring Boot Dev工具(Spring Remote)，并自动将重新编译的文件上传到我的docker容器。
浏览 0提问于2017-03-13得票数 6
这不是一个大问题，但我很好奇，一些额外的流消费者来自哪里，如果这是一个设置，我可以改变。}
不过，当我运行这个应用程序时，我可以看到在输出中创建了3个消费者但是，当我检查本地代理中的消费者组成员时，它总是一
浏览 7提问于2021-04-14得票数 0
回答已采纳
我使用的是Spring Boot2.1.1.RELEASE和Spring Cloud Greenwich.RC2，spring-cloud-stream-binder-kafka的托管版本是2.1.0RC4spring.cloud.stream.bindings.input.group=consumer-gp-1spring.cloud.stream.kafka.bindings.input.consumer.autoCommitOnError过了一段时间后，我停止并重新启动了
浏览 29提问于2019-03-18得票数 2
1回答
完全不可变容器的好处
、、、
在更新配置时重启容器而不是在运行时更新配置有什么实际好处(例如Spring Boot支持监听ConfigMap更改或Spring Cloud Config Server具有此功能)？我实际上看不到任何东西，我可以看到一些缺点，比如需要重置TCP连接。
浏览 28提问于2020-07-07得票数 0
"participantList", participantList);}
} 我希望能够:每次将姓名列表输入到表单时，我希望它们在按下“保存当前姓名”按钮时被保存，以便以后可以通过从下拉框中选择它们，然后单击“加载”按钮，将它们再次加载到另一个页面上。整个应用程序是一个排行榜，所以我希望相同的参与者能够被保存，例如，当学校的某个班级需要使用排行榜时，它可以被加载。 这是否需要使用数据库，或
浏览 9提问于2019-03-11得票数 1
1回答
我正在开发一个使用Kafka流的spring boot应用程序，在我的应用程序中，我希望管理Kafka偏移量，并在仅在成功处理消息的情况下提交偏移量。这一点很重要，确保即使Kafka重启或zookeeper关闭，我也不会丢失消息。我目前的情况是，当我的Kafka断断续续时，我的消费者从头开始并使用所有之前的消息。
浏览 3提问于2020-01-16得票数 0
1回答
我使用了一个带有IntegrationFlows的spring boot应用程序，并使用了测微仪来显示指标。当流程开始时，我看到一个名为spring_integration_send_seconds_count的指标，表示已处理的数据，在流程完成后，相同的指标如预期的那样变为零。但是，在应用程序重新启动时，此指标不存在，这会导致应用PromQL函数时出现问题。无法预测流运行的频率。我确实在https://docs.sprin
浏览 29提问于2020-08-27得票数 0
回答已采纳
我正在使用一个Spring Boot应用程序。并且我已经包含了使用REST API端点的http活动探测配置。因此，每当REST API不可访问时，Kubernetes将重新启动pod。问题是，我需要确定是否有任何方式区分pod重启活动是由活动探测触发的，还是由部署团队完成的手动重启。
在Spring Boot日志中是否包含Kubernetes重启pod时的日志消息？
浏览 16提问于2021-02-19得票数 0
我有使用spring.cloud.stream.kafka.binder.brokers=KAFKA_URL spring.cloud.stream.kafka.binder.zkNodes=ZKNODE_URL的消费者
如果我尝试运行spring boot消费者应用程序，但bean未启动，则整个spring boot应用程序无法启动: rg.springframework.context.ApplicationCo
浏览 4提问于2017-03-21得票数 0
正如我们所知，org.springframework.boot支持热部署来检测任何更改，而无需重启应用程序。当我用mvn spring-boot:run运行它时，它可以与maven一起工作，但当我用gradle bootRun运行它时，它就不能工作了，它不能自动检测属性文件的变化。compile group: 'org.springframework.boot', name: '
浏览 1提问于2018-09-11得票数 1
我使用的是带有spring boot的thymeleaf，我的index.html位于src/main/resources/template中，每次我想要看到更改时，我必须停止服务器，更新项目，并重新运行应用程序，这是非常低效的，我只想运行和刷新，我将devtools添加到我的依赖项中，并设置spring.thymeleaf.cache= false，但它仍然不起作用
浏览 0提问于2019-04-26得票数 0
我试图在一个消费者组中创建多个消费者，以便进行并行处理，因为我们有大量的消息流入。我使用的是spring boot和KafkTemplate。如何在spring boot应用程序的单个实例中创建属于单个消费者组的多个消费者？使用@KafkaListener注释多个方法会创建多个消费者吗？
浏览 121提问于2020-07-01得票数 2
回答已采纳
URLs for reloading : [file:/some/where/build/classes/main/, 每当我更改一个控制器文件时因此，我提到我应该尝试将spring.devtools.restart.additional-paths=/src添加到我的应用程序属性文件中。这样做之后，向我的控制器文
浏览 19提问于2017-07-19得票数 3
我在一个消费者组中有多个消费者(单个Spring Boot应用程序)。我使用onPartitionsAssigned回调将每个消费者偏移量重置为最新(对于分配的分区)。问题是，我需要知道消费者组中的所有消费者何时执行了这一搜索，并在此之后执行一些逻辑。 我目前的理解是，每个使用者都独立地执行查找和开始处理-即没有任何公共同步点。但在发送此请求之前，我需要确保所有消费者已经处于最新的偏移量。因为如果这个请求发送得更早-
浏览 28提问于2021-07-22得票数 0
我正在使用Spring Boot，我有一个用例，用户可以上传一个文件，这应该会导致应用程序重启(因为用户的上传是在创建多个bean的过程中使用的)。我知道我可以避免重启应用程序，但是现在--这就是我想要的。
我在Spring-Cloud项目中发现了，但看起来ApplicationPreparedEvent并没有被解雇。有没有其他方法可以通过编程方式重启Spring Boot应用程序？
浏览 1提问于2015-03-18得票数 12
2回答
我是spring应用程序开发的新手。 如何在tomcat服务器上开发阶段运行我的应用程序。 here我可以看到最终部署的解决方案。我只需要改变一些在ui上，每次我需要停止和重新开始。真让我难受。> <artifactId>spring-boot-starter-data-rest</artifactId>
<
浏览 17提问于2019-03-15得票数 0
回答已采纳
根据的说法，通过在pom.xml中使用spring-boot-actuator依赖项，我可以从actuator端点中获益。然而，我观察到它破坏了我现有的我的spring应用程序(它不是spring-boot应用程序)。<artifactId>spring-boot-actuator</artifactId>
<version>1.2.5.RELEASE<&#x
浏览 1提问于2015-09-04得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
