This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from c6150d00c0f camel-kudu: Make component dependency doc consistent with
other components
add a407fd82512 CAMEL-20218: On startup populate local cache synchronously
(#12948)
No new revisions were added by this update.
Summary of changes:
.../idempotent/kafka/KafkaConsumerUtil.java | 54 ++++++
.../kafka/KafkaIdempotentRepository.java | 197 +++++----------------
.../idempotent/kafka/KafkaConsumerUtilsTest.java | 167 +++++++++++++++++
.../KafkaIdempotentRepositoryPersistenceIT.java | 1 -
4 files changed, 270 insertions(+), 149 deletions(-)
create mode 100644
components/camel-kafka/src/main/java/org/apache/camel/processor/idempotent/kafka/KafkaConsumerUtil.java
create mode 100644
components/camel-kafka/src/test/java/org/apache/camel/processor/idempotent/kafka/KafkaConsumerUtilsTest.java
