This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git.
from 1e6dbbf AWS EC2: Introduce optional overrideEndpoint and
uriEndpointOverride for testing purpose
new e572451 chore: Add header deserialize option on Kafka source
new 7c959e1 chore: Kafka source uses local bean for header deserialization
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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%)
