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-kamelets.git.
from 1e6dbbf AWS EC2: Introduce optional overrideEndpoint and
uriEndpointOverride for testing purpose
add e572451 chore: Add header deserialize option on Kafka source
add 7c959e1 chore: Kafka source uses local bean for header deserialization
No new revisions were added by this update.
Summary of changes:
.github/workflows/yaks-tests.yaml | 1 +
kamelets/kafka-source.kamelet.yaml | 23 ++++-
.../kafka/KafkaHeaderDeserializer.java | 96 ++++++++++++++++++
.../kafka/KafkaHeaderDeserializerTest.java | 112 +++++++++++++++++++++
.../resources/kamelets/kafka-source.kamelet.yaml | 23 ++++-
docs/local-build.sh => test/kafka/install.sh | 18 ++--
.../kafka-sink-test.yaml} | 21 ++--
.../kafka-sink.feature} | 42 ++++----
.../kafka-source-test.yaml} | 24 ++---
test/kafka/kafka-source.feature | 66 ++++++++++++
docs/source-watch.yml => test/kafka/uninstall.sh | 15 +--
test/{mail-sink => kafka}/yaks-config.yaml | 23 +++--
12 files changed, 388 insertions(+), 76 deletions(-)
create mode 100644
library/camel-kamelets-utils/src/main/java/org/apache/camel/kamelets/utils/serialization/kafka/KafkaHeaderDeserializer.java
create mode 100644
library/camel-kamelets-utils/src/test/java/org/apache/camel/kamelets/utils/serialization/kafka/KafkaHeaderDeserializerTest.java
copy docs/local-build.sh => test/kafka/install.sh (62%)
mode change 100755 => 100644
copy test/{mail-sink/timer-to-mail.yaml => kafka/kafka-sink-test.yaml} (78%)
copy test/{insert-field-action/insert-field-action.feature =>
kafka/kafka-sink.feature} (54%)
copy test/{mail-sink/timer-to-mail.yaml => kafka/kafka-source-test.yaml} (75%)
create mode 100644 test/kafka/kafka-source.feature
copy docs/source-watch.yml => test/kafka/uninstall.sh (80%)
copy test/{mail-sink => kafka}/yaks-config.yaml (77%)
