You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/14 09:18:40 UTC
[camel-kafka-connector] branch aggr-conv-transf created (now
ba561d3)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch aggr-conv-transf
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
at ba561d3 Add converters, transforms and aggregationStrategies to catalog, fixed CS
This branch includes the following new commits:
new 668754e Add converters, transforms and aggregationStrategies to catalog
new 5b309a1 Add converters, transforms and aggregationStrategies to catalog, regen
new ba561d3 Add converters, transforms and aggregationStrategies to catalog, fixed CS
The 3 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.
[camel-kafka-connector] 02/03: Add converters,
transforms and aggregationStrategies to catalog, regen
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aggr-conv-transf
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 5b309a1a982cec71b05265dcba32a3971204774a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 10:16:39 2020 +0200
Add converters, transforms and aggregationStrategies to catalog, regen
---
.../resources/connectors/camel-aws-s3-sink.json | 5 +-
.../resources/connectors/camel-aws-s3-source.json | 5 +-
.../resources/connectors/camel-aws2-s3-sink.json | 5 +-
.../resources/connectors/camel-aws2-s3-source.json | 5 +-
.../resources/descriptors/connectors.properties | 944 ++++++++++-----------
.../src/generated/resources/camel-aws-s3-sink.json | 5 +-
.../generated/resources/camel-aws-s3-source.json | 5 +-
.../generated/resources/camel-aws2-s3-sink.json | 5 +-
.../generated/resources/camel-aws2-s3-source.json | 5 +-
9 files changed, 504 insertions(+), 480 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
index 4fed4e5..0dbb518 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-sink.json
@@ -368,5 +368,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "converters": [
+ "org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter"
+ ]
}
\ No newline at end of file
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
index 85aa25d..d0ef24c 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-source.json
@@ -448,5 +448,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "converters": [
+ "org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter"
+ ]
}
\ No newline at end of file
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json
index 78ad473..0f8809d 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-sink.json
@@ -342,5 +342,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "converters": [
+ "org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
+ ]
}
\ No newline at end of file
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json
index 89f9105..8f8b6e7 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-s3-source.json
@@ -474,5 +474,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "converters": [
+ "org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
+ ]
}
\ No newline at end of file
diff --git a/camel-kafka-connector-catalog/src/generated/resources/descriptors/connectors.properties b/camel-kafka-connector-catalog/src/generated/resources/descriptors/connectors.properties
index 5746f78..a77388e 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/descriptors/connectors.properties
+++ b/camel-kafka-connector-catalog/src/generated/resources/descriptors/connectors.properties
@@ -1,525 +1,525 @@
-camel-nagios-sink
-camel-hazelcast-atomicvalue-sink
-camel-aws2-kinesis-firehose-sink
-camel-metrics-sink
-camel-aws2-sqs-source
-camel-aws2-sqs-sink
-camel-rest-swagger-sink
-camel-snmp-source
-camel-snmp-sink
-camel-beanstalk-source
-camel-beanstalk-sink
-camel-jolt-sink
-camel-jpa-source
-camel-jpa-sink
camel-activemq-source
camel-activemq-sink
-camel-github-source
-camel-github-sink
-camel-sips-source
-camel-sips-sink
-camel-openstack-keystone-sink
+camel-ahc-sink
+camel-ahc-ws-source
+camel-ahc-ws-sink
camel-ahc-wss-source
camel-ahc-wss-sink
-camel-grape-sink
+camel-amqp-source
+camel-amqp-sink
+camel-apns-source
+camel-apns-sink
camel-arangodb-sink
-camel-xslt-sink
-camel-mustache-sink
+camel-as2-source
+camel-as2-sink
camel-asterisk-source
camel-asterisk-sink
-camel-rss-source
-camel-aws-ec2-sink
+camel-atmos-source
+camel-atmos-sink
+camel-atmosphere-websocket-source
+camel-atmosphere-websocket-sink
+camel-atom-source
+camel-atomix-map-source
+camel-atomix-map-sink
+camel-atomix-messaging-source
+camel-atomix-messaging-sink
+camel-atomix-multimap-sink
+camel-atomix-queue-source
+camel-atomix-queue-sink
+camel-atomix-set-source
+camel-atomix-set-sink
camel-atomix-value-source
camel-atomix-value-sink
-camel-netty-http-source
-camel-netty-http-sink
-camel-optaplanner-source
-camel-optaplanner-sink
-camel-jslt-sink
-camel-scheduler-source
-camel-google-sheets-stream-source
-camel-imap-source
-camel-imap-sink
-camel-stomp-source
-camel-stomp-sink
-camel-stub-source
-camel-stub-sink
-camel-ignite-events-source
-camel-kubernetes-hpa-source
-camel-kubernetes-hpa-sink
-camel-vertx-websocket-source
-camel-vertx-websocket-sink
-camel-jooq-source
-camel-jooq-sink
-camel-weather-source
-camel-weather-sink
-camel-google-mail-source
-camel-google-mail-sink
-camel-djl-sink
-camel-cm-sms-sink
-camel-rest-source
-camel-rest-sink
-camel-sjms2-source
-camel-sjms2-sink
-camel-sftp-source
-camel-sftp-sink
+camel-avro-source
+camel-avro-sink
+camel-aws-cw-sink
+camel-aws-ddb-sink
+camel-aws-ddbstream-source
+camel-aws-kinesis-firehose-sink
+camel-aws-kinesis-source
+camel-aws-kinesis-sink
+camel-aws-lambda-sink
+camel-aws-s3-source
+camel-aws-s3-sink
+camel-aws-sdb-sink
+camel-aws-ses-sink
+camel-aws-sns-sink
+camel-aws-sqs-source
+camel-aws-sqs-sink
+camel-aws-swf-source
+camel-aws-swf-sink
+camel-aws-translate-sink
+camel-aws2-athena-sink
+camel-aws2-cw-sink
+camel-aws2-ddb-sink
+camel-aws2-ddbstream-source
+camel-aws2-kinesis-firehose-sink
+camel-aws2-kinesis-source
+camel-aws2-kinesis-sink
+camel-aws2-lambda-sink
+camel-aws2-s3-source
+camel-aws2-s3-sink
+camel-aws2-ses-sink
+camel-aws2-sns-sink
+camel-aws2-sqs-source
+camel-aws2-sqs-sink
+camel-aws2-sts-sink
+camel-aws2-translate-sink
+camel-azure-blob-source
+camel-azure-blob-sink
+camel-azure-eventhubs-source
+camel-azure-eventhubs-sink
+camel-azure-queue-source
+camel-azure-queue-sink
+camel-azure-storage-blob-source
+camel-azure-storage-blob-sink
camel-azure-storage-queue-source
camel-azure-storage-queue-sink
-camel-minio-source
-camel-minio-sink
-camel-aws2-kms-sink
-camel-chunk-sink
-camel-atomix-set-source
-camel-atomix-set-sink
-camel-aws2-sns-sink
-camel-schematron-sink
-camel-netty-source
-camel-netty-sink
-camel-undertow-source
-camel-undertow-sink
-camel-solrs-sink
-camel-google-pubsub-source
-camel-google-pubsub-sink
-camel-ahc-sink
-camel-ldif-sink
-camel-iota-sink
-camel-msv-sink
-camel-reactive-streams-source
-camel-reactive-streams-sink
-camel-micrometer-sink
-camel-webhook-source
+camel-bean-sink
+camel-beanstalk-source
+camel-beanstalk-sink
camel-box-source
camel-box-sink
-camel-kubernetes-replication-controllers-source
-camel-kubernetes-replication-controllers-sink
-camel-fhir-source
-camel-fhir-sink
-camel-openstack-nova-sink
-camel-jbpm-source
-camel-jbpm-sink
-camel-quartz-source
-camel-hazelcast-seda-source
-camel-hazelcast-seda-sink
-camel-olingo4-source
-camel-olingo4-sink
-camel-pubnub-source
-camel-pubnub-sink
-camel-openshift-builds-sink
-camel-guava-eventbus-source
-camel-guava-eventbus-sink
-camel-workday-sink
-camel-kubernetes-persistent-volumes-claims-sink
-camel-openstack-cinder-sink
-camel-dns-sink
-camel-sap-netweaver-sink
-camel-jsonata-sink
-camel-pdf-sink
+camel-braintree-source
+camel-braintree-sink
+camel-caffeine-cache-sink
+camel-caffeine-loadcache-sink
+camel-chatscript-sink
+camel-chunk-sink
+camel-cm-sms-sink
+camel-cmis-source
+camel-cmis-sink
+camel-coap-source
+camel-coap-sink
+camel-coap-tcp-source
+camel-coap-tcp-sink
+camel-coaps-source
+camel-coaps-sink
camel-coaps-tcp-source
camel-coaps-tcp-sink
-camel-lumberjack-source
-camel-pulsar-source
-camel-pulsar-sink
-camel-aws2-ec2-sink
-camel-jdbc-sink
-camel-xmpp-source
-camel-xmpp-sink
-camel-master-source
-camel-seda-source
-camel-seda-sink
-camel-file-source
-camel-file-sink
-camel-olingo2-source
-camel-olingo2-sink
-camel-aws2-s3-source
-camel-aws2-s3-sink
-camel-mllp-source
-camel-mllp-sink
-camel-pop3s-source
-camel-pop3s-sink
-camel-mvel-sink
-camel-hazelcast-ringbuffer-sink
-camel-aws2-msk-sink
-camel-imaps-source
-camel-imaps-sink
-camel-hazelcast-list-source
-camel-hazelcast-list-sink
-camel-service-source
-camel-telegram-source
-camel-telegram-sink
-camel-twitter-directmessage-source
-camel-twitter-directmessage-sink
-camel-kubernetes-service-accounts-sink
-camel-solrCloud-sink
-camel-google-calendar-stream-source
-camel-ipfs-sink
-camel-smtp-source
-camel-smtp-sink
+camel-cometd-source
+camel-cometd-sink
camel-cometds-source
camel-cometds-sink
-camel-git-source
-camel-git-sink
-camel-xquery-source
-camel-xquery-sink
-camel-file-watch-source
-camel-atomix-multimap-sink
-camel-smpp-source
-camel-smpp-sink
-camel-salesforce-source
-camel-salesforce-sink
-camel-freemarker-sink
-camel-mongodb-gridfs-source
-camel-mongodb-gridfs-sink
-camel-zookeeper-master-source
-camel-as2-source
-camel-as2-sink
-camel-timer-source
-camel-jgroups-raft-source
-camel-jgroups-raft-sink
+camel-consul-source
+camel-consul-sink
+camel-controlbus-sink
+camel-corda-source
+camel-corda-sink
camel-couchbase-source
camel-couchbase-sink
-camel-nats-source
-camel-nats-sink
-camel-aws2-sts-sink
-camel-cxfrs-source
-camel-cxfrs-sink
+camel-couchdb-source
+camel-couchdb-sink
+camel-cql-source
+camel-cql-sink
+camel-cron-source
+camel-crypto-cms-sink
+camel-crypto-sink
+camel-cxf-source
+camel-cxf-sink
+camel-cxfrs-source
+camel-cxfrs-sink
+camel-dataformat-sink
+camel-direct-source
+camel-direct-sink
+camel-direct-vm-source
+camel-direct-vm-sink
+camel-disruptor-source
+camel-disruptor-sink
+camel-disruptor-vm-source
+camel-disruptor-vm-sink
+camel-djl-sink
+camel-dns-sink
+camel-docker-source
+camel-docker-sink
+camel-dozer-sink
+camel-drill-sink
+camel-dropbox-source
+camel-dropbox-sink
+camel-ehcache-source
+camel-ehcache-sink
+camel-elasticsearch-rest-sink
+camel-elsql-source
+camel-elsql-sink
+camel-etcd-keys-sink
+camel-etcd-stats-source
+camel-etcd-stats-sink
+camel-etcd-watch-source
+camel-exec-sink
+camel-facebook-source
+camel-facebook-sink
+camel-fhir-source
+camel-fhir-sink
+camel-file-source
+camel-file-sink
+camel-file-watch-source
+camel-flatpack-source
+camel-flatpack-sink
+camel-flink-sink
+camel-fop-sink
+camel-freemarker-sink
+camel-ftp-source
+camel-ftp-sink
+camel-ftps-source
+camel-ftps-sink
+camel-ganglia-sink
+camel-geocoder-sink
+camel-git-source
+camel-git-sink
+camel-github-source
+camel-github-sink
+camel-google-bigquery-sink
+camel-google-bigquery-sql-sink
+camel-google-calendar-source
+camel-google-calendar-sink
+camel-google-calendar-stream-source
+camel-google-drive-source
+camel-google-drive-sink
+camel-google-mail-source
+camel-google-mail-sink
+camel-google-mail-stream-source
+camel-google-pubsub-source
+camel-google-pubsub-sink
+camel-google-sheets-source
+camel-google-sheets-sink
+camel-google-sheets-stream-source
+camel-gora-source
+camel-gora-sink
+camel-grape-sink
+camel-graphql-sink
+camel-grpc-source
+camel-grpc-sink
+camel-guava-eventbus-source
+camel-guava-eventbus-sink
+camel-hazelcast-atomicvalue-sink
+camel-hazelcast-instance-source
+camel-hazelcast-list-source
+camel-hazelcast-list-sink
+camel-hazelcast-map-source
+camel-hazelcast-map-sink
+camel-hazelcast-multimap-source
+camel-hazelcast-multimap-sink
+camel-hazelcast-queue-source
+camel-hazelcast-queue-sink
+camel-hazelcast-replicatedmap-source
+camel-hazelcast-replicatedmap-sink
+camel-hazelcast-ringbuffer-sink
+camel-hazelcast-seda-source
+camel-hazelcast-seda-sink
+camel-hazelcast-set-source
+camel-hazelcast-set-sink
+camel-hazelcast-topic-source
+camel-hazelcast-topic-sink
+camel-hbase-source
+camel-hbase-sink
camel-hdfs-source
camel-hdfs-sink
+camel-hipchat-source
+camel-hipchat-sink
+camel-http-sink
+camel-https-sink
+camel-iec60870-client-source
+camel-iec60870-client-sink
+camel-iec60870-server-source
+camel-iec60870-server-sink
+camel-ignite-cache-source
+camel-ignite-cache-sink
+camel-ignite-compute-sink
+camel-ignite-events-source
+camel-ignite-idgen-sink
+camel-ignite-messaging-source
+camel-ignite-messaging-sink
+camel-ignite-queue-sink
+camel-ignite-set-sink
+camel-imap-source
+camel-imap-sink
+camel-imaps-source
+camel-imaps-sink
+camel-infinispan-source
+camel-infinispan-sink
+camel-influxdb-sink
+camel-iota-sink
+camel-ipfs-sink
+camel-irc-source
+camel-irc-sink
+camel-ironmq-source
+camel-ironmq-sink
+camel-jbpm-source
+camel-jbpm-sink
+camel-jcache-source
+camel-jcache-sink
+camel-jclouds-source
+camel-jclouds-sink
+camel-jcr-source
+camel-jcr-sink
+camel-jdbc-sink
+camel-jetty-source
+camel-jgroups-source
+camel-jgroups-sink
+camel-jgroups-raft-source
+camel-jgroups-raft-sink
+camel-jing-sink
+camel-jira-source
+camel-jira-sink
camel-jms-source
camel-jms-sink
-camel-stax-sink
-camel-braintree-source
-camel-braintree-sink
-camel-hazelcast-queue-source
-camel-hazelcast-queue-sink
-camel-aws2-translate-sink
-camel-smpps-source
-camel-smpps-sink
-camel-atomix-messaging-source
-camel-atomix-messaging-sink
-camel-scp-sink
-camel-bean-sink
-camel-aws-sns-sink
+camel-jmx-source
+camel-jolt-sink
+camel-jooq-source
+camel-jooq-sink
+camel-jpa-source
+camel-jpa-sink
+camel-jslt-sink
+camel-json-validator-sink
+camel-jsonata-sink
+camel-jt400-source
+camel-jt400-sink
+camel-kubernetes-config-maps-sink
+camel-kubernetes-deployments-source
+camel-kubernetes-deployments-sink
+camel-kubernetes-hpa-source
+camel-kubernetes-hpa-sink
+camel-kubernetes-job-source
+camel-kubernetes-job-sink
+camel-kubernetes-namespaces-source
+camel-kubernetes-namespaces-sink
+camel-kubernetes-nodes-source
+camel-kubernetes-nodes-sink
+camel-kubernetes-persistent-volumes-claims-sink
+camel-kubernetes-persistent-volumes-sink
+camel-kubernetes-pods-source
+camel-kubernetes-pods-sink
+camel-kubernetes-replication-controllers-source
+camel-kubernetes-replication-controllers-sink
+camel-kubernetes-resources-quota-sink
+camel-kubernetes-secrets-sink
+camel-kubernetes-service-accounts-sink
+camel-kubernetes-services-source
+camel-kubernetes-services-sink
+camel-kudu-sink
+camel-language-sink
+camel-ldap-sink
+camel-ldif-sink
+camel-log-sink
+camel-lpr-sink
+camel-lucene-sink
+camel-lumberjack-source
+camel-master-source
+camel-metrics-sink
+camel-micrometer-sink
+camel-microprofile-metrics-sink
+camel-milo-client-source
+camel-milo-client-sink
+camel-milo-server-source
+camel-milo-server-sink
camel-mina-source
camel-mina-sink
-camel-spring-ldap-sink
-camel-aws-msk-sink
-camel-google-bigquery-sql-sink
+camel-minio-source
+camel-minio-sink
+camel-mllp-source
+camel-mllp-sink
+camel-mongodb-gridfs-source
+camel-mongodb-gridfs-sink
+camel-mongodb-source
+camel-mongodb-sink
+camel-msv-sink
+camel-mustache-sink
+camel-mvel-sink
+camel-mybatis-bean-sink
camel-mybatis-source
camel-mybatis-sink
-camel-ssh-source
-camel-ssh-sink
-camel-hipchat-source
-camel-hipchat-sink
-camel-direct-vm-source
-camel-direct-vm-sink
-camel-coap-tcp-source
-camel-coap-tcp-sink
+camel-nagios-sink
+camel-nats-source
+camel-nats-sink
+camel-netty-http-source
+camel-netty-http-sink
+camel-netty-source
+camel-netty-sink
camel-nitrite-source
camel-nitrite-sink
-camel-kubernetes-job-source
-camel-kubernetes-job-sink
-camel-hazelcast-instance-source
-camel-servicenow-sink
-camel-stream-source
-camel-stream-sink
-camel-aws-mq-sink
-camel-aws-kinesis-firehose-sink
-camel-lucene-sink
-camel-servlet-source
-camel-aws-ddbstream-source
-camel-vertx-http-sink
-camel-grpc-source
-camel-grpc-sink
-camel-etcd-keys-sink
-camel-etcd-stats-source
-camel-etcd-stats-sink
-camel-jetty-source
-camel-ignite-cache-source
-camel-ignite-cache-sink
-camel-splunk-source
-camel-splunk-sink
+camel-nsq-source
+camel-nsq-sink
camel-oaipmh-source
camel-oaipmh-sink
-camel-cxf-source
-camel-cxf-sink
-camel-avro-source
-camel-avro-sink
-camel-aws-ses-sink
-camel-flink-sink
-camel-spring-integration-source
-camel-spring-integration-sink
+camel-olingo2-source
+camel-olingo2-sink
+camel-olingo4-source
+camel-olingo4-sink
+camel-openshift-build-configs-sink
+camel-openshift-builds-sink
+camel-openstack-cinder-sink
+camel-openstack-glance-sink
+camel-openstack-keystone-sink
+camel-openstack-neutron-sink
+camel-openstack-nova-sink
+camel-openstack-swift-sink
+camel-optaplanner-source
+camel-optaplanner-sink
camel-paho-source
camel-paho-sink
-camel-aws-translate-sink
-camel-docker-source
-camel-docker-sink
-camel-azure-queue-source
-camel-azure-queue-sink
-camel-iec60870-client-source
-camel-iec60870-client-sink
-camel-jcr-source
-camel-jcr-sink
-camel-sql-source
-camel-sql-sink
-camel-dataformat-sink
-camel-sip-source
-camel-sip-sink
-camel-ftp-source
-camel-ftp-sink
-camel-yammer-source
-camel-yammer-sink
-camel-solr-sink
-camel-xj-sink
+camel-pdf-sink
+camel-pg-replication-slot-source
camel-pgevent-source
camel-pgevent-sink
-camel-infinispan-source
-camel-infinispan-sink
-camel-xchange-sink
-camel-spring-batch-sink
-camel-milo-server-source
-camel-milo-server-sink
-camel-cql-source
-camel-cql-sink
-camel-atmos-source
-camel-atmos-sink
-camel-crypto-cms-sink
-camel-cmis-source
-camel-cmis-sink
-camel-azure-eventhubs-source
-camel-azure-eventhubs-sink
-camel-sjms-source
-camel-sjms-sink
-camel-aws-sdb-sink
-camel-caffeine-loadcache-sink
-camel-xmlsecurity-sign-sink
-camel-xslt-saxon-sink
-camel-aws2-ddbstream-source
-camel-aws2-ecs-sink
-camel-aws2-mq-sink
-camel-atomix-map-source
-camel-atomix-map-sink
-camel-twilio-source
-camel-twilio-sink
-camel-aws-iam-sink
-camel-microprofile-metrics-sink
+camel-platform-http-source
camel-pop3-source
camel-pop3-sink
-camel-saga-sink
-camel-exec-sink
-camel-tika-sink
-camel-cron-source
-camel-ahc-ws-source
-camel-ahc-ws-sink
-camel-aws2-eks-sink
-camel-ironmq-source
-camel-ironmq-sink
-camel-aws-s3-source
-camel-aws-s3-sink
-camel-weka-sink
-camel-kubernetes-namespaces-source
-camel-kubernetes-namespaces-sink
+camel-pop3s-source
+camel-pop3s-sink
+camel-pubnub-source
+camel-pubnub-sink
+camel-pulsar-source
+camel-pulsar-sink
+camel-quartz-source
+camel-quickfix-source
+camel-quickfix-sink
+camel-rabbitmq-source
+camel-rabbitmq-sink
+camel-reactive-streams-source
+camel-reactive-streams-sink
+camel-rest-api-source
+camel-rest-source
+camel-rest-sink
+camel-rest-openapi-sink
+camel-rest-swagger-sink
camel-resteasy-source
camel-resteasy-sink
-camel-iec60870-server-source
-camel-iec60870-server-sink
-camel-google-sheets-source
-camel-google-sheets-sink
-camel-splunk-hec-sink
-camel-etcd-watch-source
-camel-openstack-neutron-sink
-camel-jcache-source
-camel-jcache-sink
-camel-slack-source
-camel-slack-sink
-camel-aws-ecs-sink
-camel-json-validator-sink
-camel-atmosphere-websocket-source
-camel-atmosphere-websocket-sink
-camel-websocket-source
-camel-websocket-sink
-camel-crypto-sink
-camel-facebook-source
-camel-facebook-sink
-camel-language-sink
-camel-web3j-source
-camel-web3j-sink
-camel-dozer-sink
-camel-aws-lambda-sink
-camel-aws2-ses-sink
-camel-graphql-sink
-camel-google-drive-source
-camel-google-drive-sink
-camel-ignite-idgen-sink
-camel-disruptor-source
-camel-disruptor-sink
-camel-log-sink
-camel-jmx-source
-camel-ldap-sink
-camel-controlbus-sink
+camel-rss-source
+camel-saga-sink
+camel-salesforce-source
+camel-salesforce-sink
+camel-sap-netweaver-sink
+camel-scheduler-source
+camel-schematron-sink
+camel-scp-sink
+camel-seda-source
+camel-seda-sink
+camel-service-source
+camel-servicenow-sink
+camel-servlet-source
+camel-sftp-source
+camel-sftp-sink
+camel-sip-source
+camel-sip-sink
+camel-sips-source
+camel-sips-sink
+camel-sjms-batch-source
+camel-sjms-source
+camel-sjms-sink
+camel-sjms2-source
+camel-sjms2-sink
+camel-slack-source
+camel-slack-sink
+camel-smpp-source
+camel-smpp-sink
+camel-smpps-source
+camel-smpps-sink
+camel-smtp-source
+camel-smtp-sink
+camel-smtps-source
+camel-smtps-sink
+camel-snmp-source
+camel-snmp-sink
+camel-solr-sink
+camel-solrCloud-sink
+camel-solrs-sink
+camel-soroush-source
+camel-soroush-sink
+camel-spark-sink
+camel-splunk-hec-sink
+camel-splunk-source
+camel-splunk-sink
+camel-spring-batch-sink
camel-spring-event-source
camel-spring-event-sink
-camel-zendesk-source
-camel-zendesk-sink
-camel-amqp-source
-camel-amqp-sink
+camel-spring-integration-source
+camel-spring-integration-sink
+camel-spring-ldap-sink
+camel-spring-redis-source
+camel-spring-redis-sink
camel-spring-ws-source
camel-spring-ws-sink
-camel-hazelcast-replicatedmap-source
-camel-hazelcast-replicatedmap-sink
-camel-geocoder-sink
-camel-aws2-lambda-sink
-camel-dropbox-source
-camel-dropbox-sink
-camel-ehcache-source
-camel-ehcache-sink
-camel-rest-openapi-sink
-camel-aws-sqs-source
-camel-aws-sqs-sink
-camel-kubernetes-config-maps-sink
-camel-aws-ddb-sink
-camel-mongodb-source
-camel-mongodb-sink
-camel-openstack-swift-sink
-camel-consul-source
-camel-consul-sink
-camel-aws-swf-source
-camel-aws-swf-sink
-camel-hazelcast-set-source
-camel-hazelcast-set-sink
-camel-jing-sink
-camel-caffeine-cache-sink
-camel-chatscript-sink
-camel-jgroups-source
-camel-jgroups-sink
-camel-hazelcast-multimap-source
-camel-hazelcast-multimap-sink
-camel-kubernetes-pods-source
-camel-kubernetes-pods-sink
-camel-ignite-compute-sink
-camel-couchdb-source
-camel-couchdb-sink
-camel-xmlsecurity-verify-sink
-camel-twitter-timeline-source
-camel-twitter-timeline-sink
-camel-kubernetes-persistent-volumes-sink
-camel-ignite-queue-sink
-camel-http-sink
-camel-nsq-source
-camel-nsq-sink
-camel-kubernetes-services-source
-camel-kubernetes-services-sink
-camel-aws2-athena-sink
+camel-sql-source
+camel-sql-sink
+camel-sql-stored-sink
+camel-ssh-source
+camel-ssh-sink
+camel-stax-sink
+camel-stomp-source
+camel-stomp-sink
+camel-stream-source
+camel-stream-sink
+camel-string-template-sink
+camel-stub-source
+camel-stub-sink
+camel-telegram-source
+camel-telegram-sink
camel-thrift-source
camel-thrift-sink
-camel-aws2-cw-sink
-camel-aws-cw-sink
-camel-jt400-source
-camel-jt400-sink
-camel-kafka-source
-camel-kafka-sink
-camel-smtps-source
-camel-smtps-sink
-camel-irc-source
-camel-irc-sink
-camel-azure-blob-source
-camel-azure-blob-sink
-camel-jclouds-source
-camel-jclouds-sink
-camel-string-template-sink
-camel-ignite-set-sink
-camel-pg-replication-slot-source
-camel-hazelcast-map-source
-camel-hazelcast-map-sink
-camel-flatpack-source
-camel-flatpack-sink
-camel-kubernetes-secrets-sink
+camel-tika-sink
+camel-timer-source
+camel-twilio-source
+camel-twilio-sink
+camel-twitter-directmessage-source
+camel-twitter-directmessage-sink
+camel-twitter-search-source
+camel-twitter-search-sink
+camel-twitter-timeline-source
+camel-twitter-timeline-sink
+camel-undertow-source
+camel-undertow-sink
+camel-validator-sink
camel-velocity-sink
-camel-coap-source
-camel-coap-sink
-camel-aws2-iam-sink
-camel-google-bigquery-sink
-camel-sql-stored-sink
-camel-platform-http-source
-camel-rabbitmq-source
-camel-rabbitmq-sink
-camel-kubernetes-resources-quota-sink
-camel-direct-source
-camel-direct-sink
-camel-zookeeper-source
-camel-zookeeper-sink
-camel-atomix-queue-source
-camel-atomix-queue-sink
-camel-drill-sink
-camel-influxdb-sink
-camel-openshift-build-configs-sink
-camel-aws-eks-sink
-camel-spark-sink
-camel-kubernetes-nodes-source
-camel-kubernetes-nodes-sink
-camel-ganglia-sink
-camel-aws2-ddb-sink
-camel-cometd-source
-camel-cometd-sink
-camel-jira-source
-camel-jira-sink
-camel-hazelcast-topic-source
-camel-hazelcast-topic-sink
+camel-vertx-http-sink
camel-vertx-source
camel-vertx-sink
-camel-https-sink
-camel-google-calendar-source
-camel-google-calendar-sink
-camel-validator-sink
+camel-vertx-websocket-source
+camel-vertx-websocket-sink
camel-vm-source
camel-vm-sink
-camel-twitter-search-source
-camel-twitter-search-sink
-camel-google-mail-stream-source
-camel-corda-source
-camel-corda-sink
-camel-kudu-sink
-camel-spring-redis-source
-camel-spring-redis-sink
-camel-coaps-source
-camel-coaps-sink
-camel-openstack-glance-sink
-camel-gora-source
-camel-gora-sink
-camel-ftps-source
-camel-ftps-sink
-camel-elsql-source
-camel-elsql-sink
-camel-aws2-kinesis-source
-camel-aws2-kinesis-sink
-camel-kubernetes-deployments-source
-camel-kubernetes-deployments-sink
-camel-fop-sink
+camel-weather-source
+camel-weather-sink
+camel-web3j-source
+camel-web3j-sink
+camel-webhook-source
+camel-websocket-jsr356-source
+camel-websocket-jsr356-sink
+camel-websocket-source
+camel-websocket-sink
+camel-weka-sink
camel-wordpress-source
camel-wordpress-sink
-camel-azure-storage-blob-source
-camel-azure-storage-blob-sink
-camel-disruptor-vm-source
-camel-disruptor-vm-sink
-camel-rest-api-source
+camel-workday-sink
+camel-xchange-sink
+camel-xj-sink
+camel-xmlsecurity-sign-sink
+camel-xmlsecurity-verify-sink
+camel-xmpp-source
+camel-xmpp-sink
+camel-xquery-source
+camel-xquery-sink
+camel-xslt-sink
+camel-xslt-saxon-sink
+camel-yammer-source
+camel-yammer-sink
+camel-zendesk-source
+camel-zendesk-sink
+camel-zookeeper-source
+camel-zookeeper-sink
+camel-zookeeper-master-source
+camel-aws-ec2-sink
+camel-aws-ecs-sink
+camel-aws-eks-sink
+camel-aws-iam-sink
camel-aws-kms-sink
-camel-elasticsearch-rest-sink
-camel-quickfix-source
-camel-quickfix-sink
-camel-soroush-source
-camel-soroush-sink
-camel-sjms-batch-source
-camel-aws-kinesis-source
-camel-aws-kinesis-sink
-camel-milo-client-source
-camel-milo-client-sink
-camel-hbase-source
-camel-hbase-sink
-camel-apns-source
-camel-apns-sink
-camel-websocket-jsr356-source
-camel-websocket-jsr356-sink
-camel-mybatis-bean-sink
-camel-atom-source
-camel-lpr-sink
-camel-ignite-messaging-source
-camel-ignite-messaging-sink
+camel-aws-mq-sink
+camel-aws-msk-sink
+camel-aws2-ec2-sink
+camel-aws2-ecs-sink
+camel-aws2-eks-sink
+camel-aws2-iam-sink
+camel-aws2-kms-sink
+camel-aws2-mq-sink
+camel-aws2-msk-sink
+camel-kafka-source
+camel-kafka-sink
diff --git a/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-sink.json b/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-sink.json
index 4fed4e5..0dbb518 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-sink.json
+++ b/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-sink.json
@@ -368,5 +368,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "converters": [
+ "org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter"
+ ]
}
\ No newline at end of file
diff --git a/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-source.json b/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-source.json
index 85aa25d..d0ef24c 100644
--- a/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-source.json
+++ b/connectors/camel-aws-s3-kafka-connector/src/generated/resources/camel-aws-s3-source.json
@@ -448,5 +448,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "converters": [
+ "org.apache.camel.kafkaconnector.awss3.converters.S3ObjectConverter"
+ ]
}
\ No newline at end of file
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
index 78ad473..0f8809d 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
+++ b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
@@ -342,5 +342,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "converters": [
+ "org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
+ ]
}
\ No newline at end of file
diff --git a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
index 89f9105..8f8b6e7 100644
--- a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
+++ b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
@@ -474,5 +474,8 @@
"description": "Amazon AWS Secret Key",
"priority": "MEDIUM"
}
- }
+ },
+ "converters": [
+ "org.apache.camel.kafkaconnector.aws2s3.converters.S3ObjectConverter"
+ ]
}
\ No newline at end of file
[camel-kafka-connector] 01/03: Add converters,
transforms and aggregationStrategies to catalog
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aggr-conv-transf
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 668754e2124e7fdc37c579a6961fdeb2cfd100e3
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 09:24:13 2020 +0200
Add converters, transforms and aggregationStrategies to catalog
---
.../kafkaconnector/maven/utils/JsonMapperKafkaConnector.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java
index 9f75272..992c24d 100644
--- a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java
+++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java
@@ -20,6 +20,7 @@ import java.util.List;
import org.apache.camel.kafkaconnector.model.CamelKafkaConnectorModel;
import org.apache.camel.kafkaconnector.model.CamelKafkaConnectorOptionModel;
+import org.apache.camel.util.json.JsonArray;
import org.apache.camel.util.json.JsonObject;
public final class JsonMapperKafkaConnector {
@@ -41,6 +42,15 @@ public final class JsonMapperKafkaConnector {
JsonObject wrapper = new JsonObject();
wrapper.put("connector", obj);
wrapper.put("properties", asJsonObject(model.getOptions()));
+ if (model.getConverters().size() > 0) {
+ wrapper.put("converters", new JsonArray(model.getConverters()));
+ }
+ if (model.getTransforms().size() > 0) {
+ wrapper.put("transforms", new JsonArray(model.getTransforms()));
+ }
+ if (model.getAggregationStrategies().size() > 0) {
+ wrapper.put("aggregationStrategies", new JsonArray(model.getAggregationStrategies()));
+ }
return wrapper;
}
[camel-kafka-connector] 03/03: Add converters,
transforms and aggregationStrategies to catalog, fixed CS
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aggr-conv-transf
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit ba561d3f55ddb77999b11b18db543a27c11fecf1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 10:36:38 2020 +0200
Add converters, transforms and aggregationStrategies to catalog, fixed CS
---
.../camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java | 9 +++++++++
.../kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java | 3 +++
.../kafkaconnector/maven/utils/JsonMapperKafkaConnector.java | 6 +++---
3 files changed, 15 insertions(+), 3 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java b/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java
index dd6a867..02c8bea 100644
--- a/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java
+++ b/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java
@@ -111,6 +111,15 @@ public class CamelKafkaConnectorCatalog {
model.setType((String)wrapper.get("type"));
model.setVersion((String)wrapper.get("version"));
model.setOptions(getConnectorOptionModel(obj));
+ if (obj.get("aggregationStrategies") != null) {
+ model.setAggregationStrategies((List<String>) obj.get("aggregationStrategies"));
+ }
+ if (obj.get("converters") != null) {
+ model.setConverters((List<String>) obj.get("converters"));
+ }
+ if (obj.get("transforms") != null) {
+ model.setTransforms((List<String>) obj.get("transforms"));
+ }
return model;
}
diff --git a/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java b/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java
index e33c720..81a67eb 100644
--- a/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java
+++ b/camel-kafka-connector-catalog/src/test/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalogTest.java
@@ -57,6 +57,9 @@ class CamelKafkaConnectorCatalogTest {
assertEquals("camel.sink.path.bucketNameOrArn", model.getOptions().get(0).getName());
assertEquals("camel.sink.endpoint.amazonS3Client", model.getOptions().get(1).getName());
assertEquals("camel.sink.endpoint.autoCreateBucket", model.getOptions().get(2).getName());
+ assertEquals(model.getConverters().size(), 1);
+ assertNull(model.getTransforms());
+ assertNull(model.getAggregationStrategies());
}
@Test
diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java
index 992c24d..08af47e 100644
--- a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java
+++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java
@@ -43,13 +43,13 @@ public final class JsonMapperKafkaConnector {
wrapper.put("connector", obj);
wrapper.put("properties", asJsonObject(model.getOptions()));
if (model.getConverters().size() > 0) {
- wrapper.put("converters", new JsonArray(model.getConverters()));
+ wrapper.put("converters", new JsonArray(model.getConverters()));
}
if (model.getTransforms().size() > 0) {
- wrapper.put("transforms", new JsonArray(model.getTransforms()));
+ wrapper.put("transforms", new JsonArray(model.getTransforms()));
}
if (model.getAggregationStrategies().size() > 0) {
- wrapper.put("aggregationStrategies", new JsonArray(model.getAggregationStrategies()));
+ wrapper.put("aggregationStrategies", new JsonArray(model.getAggregationStrategies()));
}
return wrapper;
}