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 2022/03/30 14:03:18 UTC
[camel] branch main updated (80e4991 -> 007a9a6)

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 80e4991  CAMEL-17687 - Create a Camel Azure Key Vault component - Adding client instance to configuration
     add 8123413  CAMEL-17051: record the error handling to simplify implementing pausable consumers
     add 007a9a6  (chores) camel-kafka: enable the consumer idempotent test by default

No new revisions were added by this update.

Summary of changes:
 .../camel/component/kafka/KafkaConsumer.java       |   9 +-
 .../camel/component/kafka/KafkaFetchRecords.java   | 104 +++------------------
 .../component/kafka/PollExceptionStrategy.java     |   2 +-
 .../consumer/errorhandler/BridgeErrorStrategy.java |  45 +++++++++
 .../errorhandler/DiscardErrorStrategy.java         |  40 ++++++++
 .../errorhandler/KafkaErrorStrategies.java         |  57 +++++++++++
 .../errorhandler/ReconnectErrorStrategy.java       |  44 +++++++++
 .../errorhandler/RetryErrorStrategy.java}          |  32 +++----
 .../kafka/consumer/errorhandler/SeekUtil.java      |  62 ++++++++++++
 .../errorhandler/StopErrorStrategy.java}           |  33 +++----
 .../integration/KafkaConsumerIdempotentIT.java     |   4 +-
 11 files changed, 293 insertions(+), 139 deletions(-)
 create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/errorhandler/BridgeErrorStrategy.java
 create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/errorhandler/DiscardErrorStrategy.java
 create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/errorhandler/KafkaErrorStrategies.java
 create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/errorhandler/ReconnectErrorStrategy.java
 copy components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{DefaultPollExceptionStrategy.java => consumer/errorhandler/RetryErrorStrategy.java} (50%)
 create mode 100644 components/camel-kafka/src/main/java/org/apache/camel/component/kafka/consumer/errorhandler/SeekUtil.java
 rename components/camel-kafka/src/main/java/org/apache/camel/component/kafka/{DefaultPollExceptionStrategy.java => consumer/errorhandler/StopErrorStrategy.java} (50%)