如何使用Java配置在Spring Batch中配置RetryTemplate
在Spring Batch中使用Java配置配置RetryTemplate的步骤如下：
- 导入所需的依赖：
- 导入所需的依赖：
- 创建一个RetryTemplate bean，并配置重试策略和重试监听器：
- 创建一个RetryTemplate bean，并配置重试策略和重试监听器：
- 在需要使用RetryTemplate的地方注入该bean，并使用它执行需要重试的逻辑：
- 在需要使用RetryTemplate的地方注入该bean，并使用它执行需要重试的逻辑：
以上就是使用Java配置在Spring Batch中配置RetryTemplate的步骤。RetryTemplate提供了灵活的重试策略和重试间隔的配置，可以在批处理任务执行失败时进行自动重试，提高任务的稳定性和可靠性。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云云服务器（CVM）：提供弹性计算能力，满足各类业务需求。
- 腾讯云云数据库MySQL版：高性能、可扩展的关系型数据库服务。
- 腾讯云对象存储（COS）：安全可靠的云端存储服务，适用于存储和处理大规模非结构化数据。
- 腾讯云人工智能：提供丰富的人工智能服务和解决方案，包括图像识别、语音识别、自然语言处理等。
- 腾讯云物联网（IoT）：为物联网设备提供连接、管理和数据处理能力，支持海量设备接入和数据传输。
- 腾讯云区块链服务（BCS）：提供简单易用的区块链开发和部署环境，帮助构建可信赖的区块链应用。
- 腾讯云视频处理（VOD）：提供视频上传、转码、剪辑、播放等功能，满足多媒体处理需求。
- 腾讯云音视频通信（TRTC）：提供实时音视频通信能力，支持多人音视频通话和互动直播。
- 腾讯云云原生应用引擎（TKE）：用于构建、部署和管理云原生应用的容器服务平台。
- 腾讯云网络安全（SSL证书）：提供安全可靠的SSL证书服务，保护网站和应用的数据传输安全。
- 腾讯云移动开发（移动推送）：提供移动应用推送服务，帮助开发者实现消息推送和用户管理。
- 腾讯云存储（CFS）：提供高性能、可扩展的文件存储服务，适用于大规模文件存储和共享。
- 腾讯云元宇宙（QCloud XR）：提供虚拟现实（VR）和增强现实（AR）技术和解决方案，实现沉浸式体验和交互。
相关·内容
我正在尝试在Spring Batch中设置RetryTemplate，我就是找不到如何将RetryTemplate添加到StepBuilderFactory中的示例。我在一个SpringBoot应用程序https://dzone.com/articles/how-to-use-spring-retry-template中找到了这个例子，但是在Spring Batch上没有成功。 我尝试使用RetryTemplate的原因是为了设置一个指数BackOffPolicy (Spring Batch how to configure retry period for failed jobs)。 我想
浏览 62提问于2021-06-24得票数 0
回答已采纳
我对Kafka非常陌生。我正在试图弄清楚和理解错误场景将如何为@Listener batch consumer factory工作。
我在做的是..。
我正在使用topic在batch进程中的记录，并将它们插入到DB中，如下所示.
@KafkaListener( topics = "KAFKA.TEST")
public Boolean listen(List<ConsumerRecord<String, User>> list) throws Exception {
Boolean result = null;
List<Use
浏览 4提问于2017-02-02得票数 4
我想验证一下Spring批的行为..。
在运行作业的分区步骤时，我得到了以下异常：
org.springframework.batch.core.JobExecutionException: Partition handler returned an unsuccessful step
at org.springframework.batch.core.partition.support.PartitionStep.doExecute(PartitionStep.java:111)
at org.springframework.batch.core.step.AbstractStep.exec
浏览 0提问于2014-05-09得票数 0
回答已采纳
我正面临一个奇怪的问题，一个应用程序，是一个春季引导应用程序。
详细信息：
该应用程序有一个春季批处理作业，它使用JpaItemWriter执行对数据库的写入。
此外，应用程序被配置为使用hibernate。
ItemWriter配置如下：
@Bean(name = "itemWriter")
@StepScope
public ItemWriter<Record> itemWriter() {
JpaItemWriter<Record> itemWriter = new JpaItemWriter<>();
浏览 3提问于2017-12-03得票数 8
1回答
我试图从csv文件中导入城市数据，有些数据可能会被复制，从而调用冲突错误ERROR: duplicate key value violates unique constraint "city__unique_idx" Detail: Key (country, city_name, latitude, longitude)=(231, Monticello, 30.5450000000000017, -83.8703000000000003) already exists. 2018-03-13 14:34:03.607 ERROR 13275 --- [
浏览 1提问于2018-03-13得票数 2
TL;DR：如何使用Spring作业创建Spring作业？事务边界似乎是问题所在。这似乎是一个经典的问题，但这里又来了一次：
我有以下用例:我需要轮询FTP服务器并将找到的XML文件作为blob存储在数据库中。XML有0.N个感兴趣的条目，我需要发送到外部Web服务并存储响应。响应可以是不可还原的或可还原的，我需要存储每个请求及其响应，以供审核之用。
域/JPA模型如下:批处理(包含XML )包含0-N BatchRow对象。BatchRow包含要发送到web服务的数据，它还包含1.N个BatchRowHistory对象，保存有关web服务调用的状态信息。
我被要求使用Spring来实现这个功
浏览 1提问于2013-05-01得票数 2
我正在与Spring 进行斗争，使用较新版本的Spring。首先，我尝试将ChunkRequest作为事件发送，这是不可能的，因为它没有公共的默认构造函数。作为解决方案，我必须创建一个自定义序列化程序和反序列化器，并在我的application.properties中正确地设置它们。在做了所有这些之后，现在我有了Stackoverflow。(我通过检查具有ChunkRequest集合的stepExecutions类和具有stepExecutions的jobExecution执行步骤来理解其原因)
我遗漏了什么，即使在将ChunkRequest序列化为byte[]之后？
2022-05
浏览 12提问于2022-05-13得票数 2
2回答
即使在特定配置之后，Spring流也不会在反序列化错误上重试。期望是，它应该基于配置的重试策略重试，最后将失败的消息推送到DLQ。
配置如下。
spring.cloud.stream.bindings.input_topic.consumer.maxAttempts=7
spring.cloud.stream.bindings.input_topic.consumer.backOffInitialInterval=500
spring.cloud.stream.bindings.input_topic.consumer.backOffMultiplier=10.0
spring.cloud.s
浏览 1提问于2019-06-26得票数 0
回答已采纳
我对春天，尤其是春季批次很陌生.不过，我还是设法安装了Spring批处理-管理。我为持久化添加了自定义作业和Hibernate/JPA。
一切都按预期进行，直到第一个块被持久化为止。然后收到以下错误消息：
org.springframework.transaction.CannotCreateTransactionException:
Could not open JPA EntityManager for transaction;
nested exception is java.lang.IllegalStateException: Already value
浏览 49提问于2014-01-03得票数 22
回答已采纳
1回答
我试图为DLX (绑定到另一个队列的配置)的rabbitMQ队列编写一个简单的使用者。我现在用的是骆驼3.14.5。
我的骆驼路线声明看起来是：
from("spring-rabbitmq:my-exchange?connectionFactory=#rabbitMQConnectionFactory&queues=my-queue")
.onException(Exception.class)
.log(LoggingLevel.ERROR, "Something went wrong!")
浏览 18提问于2022-09-20得票数 0
回答已采纳
我定义了下面的SimpleRetryPolicy，它可以正常工作。
<!-- -->
<batch:step id="baseStep" abstract="true">
<batch:tasklet>
<batch:chunk
reader="cvsFileItemReader"
processor="itemProcessorAsync"
writer="itemWriterAsync&#
浏览 2提问于2021-10-28得票数 0
我正在使用带有PreparedStatement的Spring，并且想要准备使用db的函数的sql。但以下内容不起作用：
String sql = "SELECT somefunct(?,?)";
当我使用prepared语句运行它时，我得到：
org.springframework.dao.DataIntegrityViolationException: PreparedStatementCallback; SQL [SELECT somefunct(?,?)]; Batch-Eintrag 0 SELECT somefunct('XX','XX
浏览 6提问于2015-01-09得票数 0
对于可能发生的异常，我使用重试模板，如下所示。retryTemplate.execute块永远不会被调用。我定义了retrytemplate bean，如下所示。不确定这是不是正确的方式。我是java和spring的新手。任何帮助都将不胜感激。
public class checkUser{
RetryTemplate retryTemplate;
public checkUser(){}
public checkUser(RetryTemplate retryTemplate){
this.retryT
浏览 1提问于2021-02-20得票数 0
我有一个简单的Spring应用程序，其中我为RabbitMQ设置了以下设置(spring starter版本为2.7.0)：
spring:
rabbitmq:
host: localhost
port: 5672
virtual-host: my_host
username: admin
password: password
template:
retry:
enabled: true
initial-interval: 3s
max-interval: 10s
m
浏览 23提问于2022-07-05得票数 0
回答已采纳
我有一个Spring Boot应用程序，它有一个JMS发布者。发布者使用了publisher类中工作正常的重试逻辑。但我想将其更改为Spring重试模板，并将其放入连接工厂配置中。
我弄不清楚如何将RetryTemplate添加到Publisher类中。
这是Configuration类：
@Configuration
@EnableRetry
public class PurchasedTransServicePublisherConfig {
@Value("${java.naming.factory.initial.publisher}")
privat
浏览 36提问于2019-07-26得票数 0
2回答
我在这个例子中尝试了spring batch重试。，并且它可以工作。我正在尝试使用retrytemplate来实现同样的功能，但是看不到抛出异常时重试不起作用。
@Configuration
@EnableBatchProcessing
//@EnableRetry
public class RetryBatchJob {
@Autowired
private JobBuilderFactory jobs;
@Autowired
priva
浏览 0提问于2018-10-15得票数 1
我试图使用@Scheduled注释运行一个春季批处理作业，如下所示：
@Scheduled(cron = "* * * * * ?")
public void launchMessageDigestMailing() throws JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException {
jobLauncher.run(messagesDigestMailingJob, new
浏览 1提问于2017-05-20得票数 6
回答已采纳
我使用Spring-Kafka2.2.8创建一个批处理消费者，并在部署我的使用者时得到一个异常。
java.lang.ClassCastException: org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter cannot be cast to org.springframework.kafka.listener.MessageListener
2020-11-11T13:38:31.97-0500 [APP/PROC/WEB/0] OUT at org.springfra
浏览 3提问于2020-11-11得票数 0
回答已采纳
我只是在这里扩展我的问题- Spring Retry doesn't works when we use RetryTemplate?。 我们如何才能在RetryContext中获得JobId？ 我通过链接：Spring Batch how to configure retry period for failed jobs，但仍然不知道。 @Component
@Slf4j
public class RecoveryCallback implements RecoveryCallback<String>{
@Autowired
private NamedP
浏览 7提问于2020-09-30得票数 1
回答已采纳
1回答
我有一个使用Spring和的服务。这个服务产生一个特定的主题，同时也使用这个主题。当我第一次启动服务并且这个主题在Kafka中不存在时，会引发以下异常：
java.lang.IllegalStateException: The number of expected partitions was: 100, but 3 have been found instead
at org.springframework.cloud.stream.binder.kafka.provisioning.KafkaTopicProvisioner$2.doWithRetry(Ka
浏览 5提问于2017-09-28得票数 1
我正在运行一个Spring批处理应用程序，它每批在Postgresql数据库中插入几千行。现在&然后，出于任何明显的原因，我们都会得到以下例外：
org.springframework.orm.jpa.JpaSystemException: nested exception is javax.persistence.PersistenceException at ...
没有什么可以告诉我们什么是 PersistenceException。它并不总是发生，也不是发生在同一个地方。我一直在研究这一异常的常见原因，并尝试了一切：
I实现了一个JPAVendorAdapter，它应该提供更好
浏览 0提问于2020-07-10得票数 3
回答已采纳
我只想在Spring重试中重试自定义异常。但是retryTemplate会重试所有异常。我的代码： try {
getRetryTemplate().execute((RetryCallback<Void, IOException>) context -> {
throw new RuntimeException("ddd"); // don't need to retry
});
} catch (IOException e) {
浏览 27提问于2019-12-17得票数 1
回答已采纳
4回答
升级到Spring 2，反应堆3.5，kafka-binder 2.0.0发行版，kafka-client 1.0.1，其中一个模块不能工作。我花了5天的时间来制作它，并且阅读了所有相关的话题，但却找不到这种行为的原因。
主修班：
@Slf4j
@EnableI18N
@EnableSideBar
@ComponentScan
@SpringBootConfiguration
@EnableConfigurationProperties
@EnableAspectJAutoProxy(proxyTargetClass = true)
public class View
{
public
浏览 1提问于2018-04-07得票数 3
回答已采纳
我正在为可还原的失败场景进行junit测试。它过去工作良好，直到我们升级到新版本的mockito和spring引导版本。我们已经更新到spring 2.4.x，并开始看到这个问题。
Service.java
public class RetryTest
{
@Autowired
private RetryTemplate retryTemplate;
@Async
private void retryTest(String in) {
retryTemplate.execute( invoke -> {
浏览 5提问于2021-07-20得票数 1
回答已采纳
我使用的是spring cloud stream。我有两个频道。一种是使用kafka cluster1，一种是使用cluster2。config就像。 spring.cloud.stream.default-binder=kafka
spring.cloud.stream.binders.kafka.type=kafka
spring.cloud.stream.binders.kafka.environment.spring.cloud.stream.kafka.binder.brokers=xxxx
spring.cloud.stream.kafka.binder.auto-add-pa
浏览 241提问于2019-04-17得票数 1
我使用的是Spring Boot & Batch示例。在本例中，我从XML读取数据，并将数据写入MySQL数据库。以下是源代码：。
在运行此示例时，我得到以下错误-
javax.persistence.TransactionRequiredException: no transaction is in progress
at org.hibernate.internal.AbstractSharedSessionContract.checkTransactionNeededForUpdateOperation(AbstractSharedSessionContract.java
浏览 1提问于2019-12-28得票数 2
1回答
jpa更新/删除查询不起作用
、、、、
服务类
@Service
public class UpdateService {
@Autowired
private ArBuildingRepository arBuildingRepository;
public void updateArBuilding(boolean newNode, String rca){
arBuildingRepository.updateByRca(newNode, rca);
}
}
repo接口中的自定义查询
public interface ArBuildingRepository extends JpaRepository&
浏览 2提问于2017-04-17得票数 1
回答已采纳
我是java和spring的新手，我正在尝试弄清楚如何接收RetryTemplate.execute命令的结果。如果execute命令失败，我想返回一个false，如果执行成功，我想返回一个true。我曾尝试在execute函数中为res赋值，但得到的结果是java: local variables referenced from a lambda expression must be final or effectively final出现错误
下面是我的代码：
private boolean forward(String message) {
boolean res;
浏览 1提问于2018-12-06得票数 0
我想知道是否有一种方法可以使用spring云流绑定卡夫卡来启用状态RetryTemplate。
我注意到有一个构造函数
RetryingMessageListenerAdapter(MessageListener<K, V> messageListener, RetryTemplate retryTemplate, RecoveryCallback<? extends Object> recoveryCallback, boolean stateful)
通过这段代码进行调试，我注意到布尔值false是使用spring云流绑定器-kafka传递给stateful参数的。
浏览 7提问于2020-05-18得票数 1
回答已采纳
在配置具有批处理编写器操作的数据源的地图作业存储库时，未显示正在进行的事务错误。请帮我解决我的spring batch hibernate配置。
这是日志。
2018-07-30 03:50:42.415 INFO 8748 --- [ main] o.s.batch.core.job.SimpleStepHandler : Executing step: [step1]
Hibernate: select next_val as id_val from hibernate_sequence for update
Hibernate: update hiberna
浏览 0提问于2018-07-30得票数 1
上下文：
我正在使用spring重试restTemplate调用。
restTemplate调用是从卡夫卡侦听器调用的。kafka侦听器还被配置为重新尝试错误(如果在进程中抛出任何异常，而不仅仅是restTemplate调用)。
目标：
当错误来自已耗尽的重试模板时，我想阻止kafka重新尝试。
实际行为:
当retryTemplate耗尽所有重试时，将引发原始异常。这样，我就无法识别错误是否被retryTemplate重试了。
期望行为：
当retryTemplate耗尽所有重试时，将原始异常包装在RetryExhaustedException中，这将允许我从卡夫卡重试中将其列入黑名单。
问
浏览 7提问于2019-10-17得票数 1
回答已采纳
我有一个春季批处理程序。
跳过限制设置为5，块大小为1000。
我有一个工作，有两个步骤，如下所示：
<step id="myFileGenerator" next="myReportGenerator">
<tasklet transaction-manager="jobRepository-transactionManager">
<chunk reader="myItemReader" processor="myItemProcessor&
浏览 0提问于2012-02-07得票数 6
回答已采纳
我使用spring(与java8lambda一起)重试失败的REST调用。我只想对那些返回500错误的呼叫重试。但我无法为此配置retrytemplate bean。当前，bean很简单，如下所示：
@Bean("restRetryTemplate")
public RetryTemplate retryTemplate() {
Map<Class<? extends Throwable>, Boolean> retryableExceptions= Collections.singletonMap(HttpServerErrorExcepti
浏览 0提问于2018-05-13得票数 4
回答已采纳
我们正在尝试将Spring-Batch作业从XML配置转换为Java配置。我们使用的是Spring 4.0.1.RELEASE和Spring Batch 2.2.1.RELEASE。
转换一个作业后，日志文件中开始出现以下警告：
fileReader 15-Apr-201409:59:26.335线程-2警告o.s.b.f.s.DisposableBeanAdapter -在名为‘fileReader’的bean上调用销毁方法'close‘失败:关闭项目读取器时出现org.springframework.batch.item.ItemStreamException:错误
完整的堆栈跟
浏览 90提问于2014-04-16得票数 27
回答已采纳
我要验证fileName和记录。我的应用程序上下文如下
<job id="job1" restartable="true" >
<step id="step1">
<tasklet>
<chunk reader="reader" writer="writter" processor="processor"
commit-interval="1" />
浏览 0提问于2014-05-03得票数 2
2回答
请看一下这个项目： --这是最小的设置，它复制了bug。
Description：应用程序栈是Spring，包含Spring和Spring。在src/main/resources/queries下有testNamedQuery.hbm.xml文件。
从应用程序类运行时，批处理作业成功完成，日志中没有异常。但是，当从ApplicationNotWorking类(这是精确的副本)运行时，只需放入测试源根，批处理作业就会失败：
Caused by: org.hibernate.MappingException: Named query not known: findPersonNames
a
浏览 2提问于2015-11-03得票数 0
看起来Spring Batch和它调用的ejb运行在同一个事务中。因此，当我们在ejb中获得回滚时，Spring Batch无法更新其在数据库中的状态。
我们得到的例外是：
org.springframework.batch.core.step.FatalStepExecutionException: JobRepository failure forcing exit with unknown status
at org.springframework.batch.core.step.tasklet.TaskletStep$ChunkTransactionCallback.d
浏览 0提问于2011-12-15得票数 1
回答已采纳
在spring批处理作业中，我有一个步骤，希望使用Hibernate从数据库中逐块读取数据，对其进行处理，然后将其写回数据库。现在我在设置阅读器时遇到了一些问题：
@EnableBatchProcessing
@Configuration
@ComponentScan(basePackages = {"com.x.y.z.database", "com.x.y.p.database"}, excludeFilters={
@ComponentScan.Filter(type= FilterType.ASSIGNABLE_TYPE, value=C
浏览 0提问于2019-07-15得票数 0
因此，我的春季批处理作业有三个步骤，第一步(Tasklet)将从共享驱动器复制文件，并将它们存储在spring project(FileSystems.getDefault()."folder_name").的文件夹中。第二步应根据业务逻辑从该文件夹和流程中读取xml文件，最后写入MultiResourceItemReader最后一步(Tasklet)将删除在步骤1中创建的文件夹。但是，在关闭作业作业中的step step1中的步骤执行资源时，必须设置o.s.batch.core.step.AbstractStep资源和o.s.batch.core.step.AbstractS
浏览 0提问于2018-10-18得票数 0
我是Spring Boot的新手，在设置RetryTemplate以重试除404以外的所有失败的异常代码时遇到了麻烦。下面是我的代码： @Bean
public RetryTemplate createRetryTemplate() {
SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
retryPolicy.setMaxAttempts(maxAttempts);
UniformRandomBackOffPolicy backOffPolicy = new UniformRandomBackOffPo
浏览 21提问于2019-10-01得票数 1
My场景：向兔子代理发布两条消息，在处理第一条消息时会发生未处理的异常。
My的问题：，为什么消息在代理中仍然是Unack的，因此为什么第二条消息不被排队和处理？
一些信息:SpringIntegration4.2.4正在使用SpringAMQP1.5.4和SpringIntegration4.2.4。(请参阅下面的代码)我已经设置了一个死信交换，它正在按预期工作(即，当我插入一条消息时，它将被转发到DLX，在那里它将过期。然后将其转发到主Exchange)。
我想要的：，我希望未处理的异常(即被SimpleMessageListenerContainer捕获的异常)导致amqp消息是Nack
浏览 3提问于2016-02-25得票数 1
回答已采纳
1回答
我从SCDF启动Spring批作业。批处理应用程序在openshift环境中部署为坞映像。SCDF与docker映像在同一个openshift环境下运行在同一个名称空间中。
为SCDF创建的配置映射运行良好。但是，当我将批处理项目的application.yaml添加到openshift配置映射中时，它在从SCDF启动时并不是由POD引用的。我给"spring.applciation.name“和config-map的"metadata.name”起了相同的名字。另外，我在批处理应用程序中添加了以下属性。但这没用。没有读取配置映射中的属性。
application.yaml
s
浏览 4提问于2020-07-24得票数 1
1回答
我很难把这个春天的xml转换成java配置。如何在下面的spring文件基础上定义adviceChain bean。
这是我的xml文件：
<util:list id="adviceChain">
<ref bean="retryInterceptor"/>
</util:list>
<bean id="retryInterceptor" class="org.springframework.amqp.rabbit.config.StatelessRetryOperationsInt
浏览 1提问于2019-08-22得票数 0
回答已采纳
我正在尝试实现spring kafka重试回调。下面是我的代码
@Bean
public ConcurrentKafkaListenerContainerFactory<String, Object> kafkaListenerContainerFactory() {
ConcurrentKafkaListenerContainerFactory<String, Object> factory = new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFacto
浏览 0提问于2020-02-13得票数 0
1回答
下一个异常将在此配置中引发：
MySQL 5.7.10
弹簧4.0.5
冬眠4.1.9
Atomikos 3.8.0
弹簧ThreadPoolTaskExecutor在10到20个线程之间
我需要Atomikos来处理两个数据库之间的事务。
例外是：
javax.persistence.PersistenceException: org.hibernate.exception.LockAcquisitionException: Deadlock found when trying to get lock; try restarting transaction
浏览 3提问于2016-09-29得票数 1
回答已采纳
当我尝试用MongoDB源代码读取的信息使用JDBC应用程序初学者时，我就面临着这个问题：
MappingException: Couldn't find PersistentEntity for type class [B!
[B类！这意味着那是一个byte[]。我在日志中打印，这是对象的JSON。这是个虫子吗？其他的水槽工作得很好。
我在本地部署中使用Spring数据流1.6.3。该应用程序的启动是在Darwin.SR1版本。
这是流定义：
jdbc --password='mypass' --query='SELECT id, name FROM myta
浏览 0提问于2018-09-30得票数 1
回答已采纳
我正在执行Spring Batch项目，该项目从Oracle读取数据并将其写入DB，当我运行批处理作业时，它会给出以下错误。
我浏览了许多链接，比如：、和，但不确定如何安装它。
jav
a.lang.Exception: Apparent connection leak detected
at com.zaxxer.hikari.HikariDataSource.getConnection(HikariDataSource.java:100) ~[HikariCP-3.4.2.jar:na]
at org.springframework.jdbc.datasource.Data
浏览 0提问于2020-06-25得票数 2
回答已采纳
使用尤里卡/功能区配置时，不会调用使用@HystrixCommand指定的回退方法，因此使用了RestTemplate。
pom.xml
....
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
浏览 78提问于2017-03-13得票数 1
2回答
我正试着用码头启动SCDF。它很好地启动，但是当尝试部署任何流时，我会在应用程序日志中得到以下错误
2017-03-09 15:19:45.864 INFO 62 --- [ main] kafka.utils.VerifiableProperties : Verifying properties
2017-03-09 15:19:45.864 INFO 62 --- [ main] kafka.utils.VerifiableProperties : Property client.id is overridden
浏览 4提问于2017-03-09得票数 1
回答已采纳
1回答
我有一个管理Spring客户端消息弹性的用例，如果RabbitMQ服务器连接中断，
同样的，我也使用了Spring重试
RabbitTemplate template = // get template from some bean
RetryTemplate retryTemplate = new RetryTemplate();
ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy();
// 10 sec
backOffPolicy.setInitialInterval(10000);
// 1 h
浏览 4提问于2017-06-01得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
