You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@camel.apache.org by or...@apache.org on 2024/01/31 09:59:42 UTC

(camel) branch main updated (c6150d00c0f -> a407fd82512)

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