micord/ervu-lkrp-fl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

SUPPORT-8591: commit after checking

Browse source
This commit is contained in:
gulnaz 2024-10-09 09:32:25 +03:00
parent 986aa01830
commit b0e1872e72
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
backend/src/main/java/ru/micord/ervu/kafka/service/impl/BaseReplyingKafkaService.java
View file

@ -66,10 +66,10 @@ public abstract class BaseReplyingKafkaService<T, V> implements ReplyingKafkaSer
if (match) {
responseRef.set(consumerRecord.value());
consumer.commitSync();
break;
}
}
consumer.commitSync();
}
return Optional.ofNullable(responseRef.get())
.orElseThrow(() -> new RuntimeException("Kafka return result is null"));