Wang Zhiyang
Wang Zhiyang
@terrymanu @TeslaCN elastic-job-lite 幂等失效场景复现 1. 开发工具 idea，idea debug 经过断点时会暂停所有线程，导致zk无法发送心跳。 2. 三个分片，开启幂等，idea启动三个实例： 3. shardingitem==1的实例打断点，位置如下： ``` public class StudyMonitorExecutionJob implements SimpleJob { private int i = 0; @Override public void execute(ShardingContext shardingContext)...
Hi, may i pick it up --- i'll chang code at https://github.com/spring-projects/spring-boot/blob/0ef87f51020939fef8c06d922dce87eab0f15190/spring-boot-project/spring-boot/src/main/java/org/springframework/boot/context/properties/source/SpringIterableConfigurationPropertySource.java#L96-L112 after change ``` java class SpringIterableConfigurationPropertySource extends SpringConfigurationPropertySource implements IterableConfigurationPropertySource, CachingConfigurationPropertySource { @Override public ConfigurationProperty getConfigurationProperty(ConfigurationPropertyName name) {...
> I have another example. See https://github.com/eddumelendez/spring-boot-sqs-testcontainers-reusable-mode Hi, @eddumelendez, @philwebb this example is `DynamicPropertyRegistry` at Development Time is not working with `@RestartScope`. `DynamicPropertyRegistry` need init property before `SqsAsyncClient`. But when...
Hi, @garyrussell, may i pick it up? I have some compatibility questions, please give me a hint. Because of ` org.apache.kafka.common.Config.SslConfigs` version in iterative process, add some properties, abandoned some...
DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method
If set the transactionTemplate to DefaultAfterRolllbackProcessor, maybe first that we need ensure `DefaultAfterRolllbackProcessor`'s `KafkaAwareTransactionManager` same as upstream components. Such as `KafkaMessageContainer`'s use this.transactionTemplate call DefaultAfterRolllbackProcessor. Please correct me if there...
DefaultAfterRollbackProcessor.isProcessInTransaction() flag should be considered in process() method
> Do you mean this.transactionTemplate? Yes, and `this.transactionTemplate` is create by `KafkaAwareTransactionManager`, maybe we need ensure `DefaultAfterRolllbackProcessor` and `KafkaMessageContainer` use the same `KafkaAwareTransactionManager`?
Hi, @philwebb may i join this task?
Hi, @philwebb Because of server need start before client get server metadata(such as ip/port), i need prove that call Container.start before create client bean. Case to be verified that create...