You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gi...@apache.org on 2022/03/30 14:52:19 UTC
[camel] branch regen_bot updated (80e4991 -> 1376663)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch regen_bot
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
add 1376663 (chores) ci: added support for running quick tests when components are changed
No new revisions were added by this update.
Summary of changes:
.github/actions/quick-test/action.yaml | 28 +++++
.github/actions/quick-test/quick-test.sh | 115 +++++++++++++++++++++
.github/workflows/master-pr-build.yml | 8 ++
.../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 +-
14 files changed, 444 insertions(+), 139 deletions(-)
create mode 100644 .github/actions/quick-test/action.yaml
create mode 100755 .github/actions/quick-test/quick-test.sh
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%)