Closed issues:
- Date templating not working in version 0.6.0 #812
Merged pull requests:
camel-kafka-connector-0.7.0 (2020-12-21)
Fixed bugs:
- Jetty conflicts in Salesforce connector #807
Closed issues:
- CamelAmqpSourceConnector example contains wrong camel.sink parameters #767
- Getting some error logs for camel.connector 3.1.0 with strimzi 0.20.0 update #766
- Add a removeHeaders option on both source and sink #763
- Added Camel-SQL kafka connector integration test #757
- Create binary distribution #754
- Possibly moving Integration tests in a separated repository? #746
- Support Poll timeout and key cache size as option for kafka idempotent repository #734
- Provide validation of properties file from the catalog #671
- Include possible enum values in Catalog #645
- [camel-main-support] Use camel's built-in support for configuring data formats trough properties #497
- Create Arangodb examples #457
Merged pull requests:
- Fix pre release #810 (valdar)
- Added Kafka idempotent repository cache size and poll timeout docs in… #809 (oscerd)
- Salesforce fixes #808 (orpiske)
- Removed repeated idempotency.enabled option in source connector basic… #806 (oscerd)
- Align SQL tests with test infra from Camel 3.7 #804 (orpiske)
- Align RabbitMQ tests with test infra from Camel 3.7 #803 (orpiske)
- Align MongoDB tests with test infra from Camel 3.7 #802 (orpiske)
- Align JDBC tests with test infra from Camel 3.7 #801 (orpiske)
- Align HDFS tests with test infra from Camel 3.7 #800 (orpiske)
- Align ElasticSearch tests with test infra from Camel 3.7 #799 (orpiske)
- Align Cassandra tests with test infra from Camel 3.7 #798 (orpiske)
- Add SJMS2 patches to master #797 (orpiske)
- Upgrade Strimzi to 0.20.1 #796 (oscerd)
- Removed staging repositories for 3.7.0 #794 (oscerd)
- Camel master sync #791 (oscerd)
- Camel-Master updated to 3.7.0 staging #789 (oscerd)
- Couchbase timeout fixes on camel-master #787 (orpiske)
- Rebase camel-master on master by hand #783 (oscerd)
- [Github Actions] Periodic Sync Camel-kafka-connector camel-master Branch #776 (github-actions[bot])
- Set the service version to the supported one from Azurite to prevent test failures #775 (orpiske)
- Fix example CamelAmqpSourceConnector using sink instead of source pro… #768 (apupier)
- Binary distribution created #765 (valdar)
- Remove headers fix #764 (oscerd)
- chore: documentation regen for 0.6.1 #761 (valdar)
- Support Poll timeout and key cache size as option for kafka idempotent repository #760 (oscerd)
- Docs update website #759 (oscerd)
- Camel-SQL Kafka Connector Added integration tests #758 (oscerd)
- Apicurio archetype docs #756 (oscerd)
- Documentation for dataformat archetype #753 (oscerd)
- Set JMS clients scope runtime to include required dependencies in the package #752 (fvaleri)
- Disable slow tests #749 (orpiske)
- fix #738 : added timestamp information to source records. #748 (valdar)
- Move SshTransforms from example/it test class directly in the camel-ssh-kafka-connector #747 (oscerd)
- Fixed Commons-io dependency version in ssh IT test #741 (oscerd)
- Camel-SSH-Kafka-connector integration test #740 (oscerd)
- Issue/715 #732 (valdar)
- Fixed wrong config references in both CamelSinkTask and CamelSourceTask #731 (oscerd)
- Prevent NPEs in the (unlikely) case the record value is null #730 (orpiske)
- Added documentation for idempotency in basic configuration docs #729 (oscerd)
- Added Support for KafkaIdempotentRepository #725 (oscerd)
- Use a Registry Ref for IdempotentRepository #722 (oscerd)
- Use the errorHandler variable coming from Builder #718 (oscerd)
- Idempotency #716 (oscerd)
- Issue/692 #714 (valdar)
- Decouple the jdbc clients from the service to simplify using the test infra from Camel #713 (orpiske)
- Add RemoteFileTransforms to the FTP connector directly #709 (oscerd)
- Add RemoteFileTransforms to the FTPS connector directly #707 (oscerd)
- Added missing dependency causing Strimzi tests to fail #706 (orpiske)
- Decouple the Azure clients from the service to simplify using the test infra from Camel #704 (orpiske)
- Review Archetype generation after new dependencies added to core #699 (oscerd)
- Avoid NPE on Windows for Catalog initialization #697 #698 (apupier)
- Added Download page #691 (oscerd)
- SFTP connector: add RemoteFileTransform #690 (oscerd)
- Remove hacktoberfest from label list #689 (oscerd)
- Added PojoToSchemaAndStructTransform to infer POJO kafka connec schem… #686 (valdar)
- AWS v2 tests tweaks #684 (orpiske)
- Provide API to retrieve Basic configuration #679 #683 (apupier)
- Minor SJMS2 test cleanups #681 (orpiske)
- fix typo #680 (apupier)
- Use foreach instead of Iterator to simplify code #678 (apupier)
- Avoid mix of stream and non-stream; simplify comparison #676 (apupier)
- 672 provide description in catalog #675 (apupier)
- Use genericity to simplify code in CamelKafkaConnectorUpdateMojo #674 (apupier)
- Remove unused private code #673 (apupier)
- Decouple the RabbitMQ client from the service to simplify using the test infra from Camel #666 (orpiske)
- Decouple the MongoDB client from the service to simplify using the test infra from Camel #662 (orpiske)
- Added a dataformat archetype for extending connectors #661 (oscerd)
- Update azure-tests #659 (unsortedhashsets)
- Index.adoc should reflect nav.adoc #658 (oscerd)
- Added a page in docs related to basic configuration of camel kafka co… #657 (oscerd)
- Added specific section in documentation related to archetype #656 (oscerd)
- Update archetypes docs to point to the latest snapshot 0.7.0 #654 (oscerd)
- Error handling 1st part #653 (oscerd)
- Minor fixes #652 (valdar)
- Provide an archetype with needed bits to use Apicurio Registry stuff #650 (oscerd)
- Added 0.6.0 to camel compatibility matrix #648 (oscerd)
- Aligned docs and link to 0.6.0 #647 (oscerd)
- Upgrade to Strimzi 0.20.0 and kafka-2.6.0 #642 (oscerd)
- Minor changes to docs - correct the camel-log and camel-timer properties file names, verbiage change on untar/unzip section. #639 (cunningt)
- Decouple the Elasticsearch client from the service to simplify moving the services to Camel core #638 (orpiske)
camel-kafka-connector-0.6.1 (2020-11-27)
Implemented enhancements:
- Review Archetype generation after new dependencies added to core #693
- Cache already computed Schemas in PojoToSchemaAndStructTransform #692
Closed issues:
- Move SshTransforms from example/it test class directly in the camel-ssh-kafka-connector #742
- Missing timestamp information #738
- Create SSH connector examples #737
- Create Twitter direct message examples #736
- Added example for AWS2-STS #727
- File language and core languages in general are not working #720
- Idempotency: Support KafkaIdempotentRepository from Camel #719
- Create the sink counterpart of the PojoToSchemaAndStructTransform #715
- Add Google Sheets Stream source example #703
- Add RemoteFileTransforms to the FTPS connector directly #702
- Add RemoteFileTransforms to the FTP connector directly #701
- Camel Kafka Connector Catalog throws NPE on Windows #697
- Create Camel Google Mail Stream Source example #696
- Create Google Calendar Stream Source Example #695
- Provide API in Camel Connector Catalog to retrieve Camel Kafka Basic configuration #679
- Provide description for connector in the catalog #672
- Add RemoteFileTransforms to the connector directly #670
- Added Git connector examples #669
- Add SFTP examples #668
- Add Simple Language support #667
- Create example for camel-pgevent connector #664
- Support Idempotency on source and sink #663
- Add an extensible connector archetype with dataformat #660
- Create a Camel-exec example #649
- Provide an archetype with needed bits to use Apicurio Registry stuff #646
- Bump to Strimzi 0.20.0 and Kafka 2.6.0 #641
- Add Twittersearch examples #637
- Add Openshift instrunctions for Telegram examples #636
- Create example for camel-resteasy-kafka-source-connector #565
- Beans aggregation size and timeout #487
- Camel-telegram wrongly parse chatId from headers #463
- Release 0.4.4 #451
- camel-azure-storage-queue-kafka-connector: Unknown parameter 'accountName' #409
Merged pull requests:
camel-kafka-connector-0.6.0 (2020-10-24)
Implemented enhancements:
- Better handling of property with no default values using
ConfigDef.NO\_DEFAULT\_VALUE
#563 - camel-kafka-connector-generator-maven-plugin: prevent the ovewrite of exixting classes unless they are @Generated annotated #146
Closed issues:
- Add the required field for connector options in docs and catalog #617
- Move ConnectRecordValueToMapTransformer of Elastisearch IT test in the connector #615
- Add a Telegram example #613
- Remove camel-hipchat from camel-master #603
- Add a file watch connector example #600
- Camel Kafka connector extensible is broken with mvnd #598
- Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have #590
- Strimzi 0.20: Lets test early with Release candidate #581
- Slack Connector: Add the slack transformer from itest to the slack connector ootb #580
- Provide API on Camel Kafka Connector to add/remove connectors dynamically #573
- Improve README #569
- Create an AWS2-Translate example #564
- Add converters, transforms and aggregationStrategies to catalog #559
- Add more convenience method to CamelKafkaConnectorCatalog #558
- Improve Catalog and cleanup #537
- Create a source distribution module #524
- Create examples with dataformat in camel-kafka-connector-examples repo #509
- [task helper] use EndpointUriFactory to generate endpoint URIs #500
- Examples instructions for Openshift too #465
- Add integration test for archetype #462
- Provide a catalog of potential configuration properties specific to Camel Kafka Connector #430
Merged pull requests:
- Switches the AWS v2 test infra-structure #635 (orpiske)
- Decouple the Cassandra client from the service to simplify moving the services to Camel core #634 (orpiske)
- Switches the AWS v1 test infra-structure #633 (orpiske)
- Switches the Kafka test infra-structure #632 (orpiske)
- Early Strimzi Test: Lets test with 0.20.0 RC3 #631 (oscerd)
- Added integration test for Couchbase sink #630 (orpiske)
- Added convenience method to get option from connector name and option name #627 (oscerd)
- Automatic changelog: Remove deprecated github action commands #626 (oscerd)
- Cleanup distribution #625 (oscerd)
- Add the required field for connector options in docs and catalog #624 (oscerd)
- cleanup core deps and leftovers #623 (lburgazzoli)
- core: use EndpointUriFactory to compute endpoint urls instead of the runtime catalog #622 (lburgazzoli)
- Removed Camel 3.6.0 staging repository #620 (oscerd)
- Move ConnectRecordValueToMapTransformer of Elastisearch IT test in the connector #618 (oscerd)
- Swap arguments so they are in the correct order: expected value, actual #616 (apupier)
- Added Release to 0.4.4 to Camel compatibility matrix #614 (oscerd)
- Staging 3.6.0 and camel master #612 (oscerd)
- JDK naming Jenkinsfiles #610 (oscerd)
- Apply the Strimzi next profile only to the connector build #608 (orpiske)
- Reneamed a method to better understanding, added a test and javadoc a… #607 (valdar)
- Catalog improve #606 (valdar)
- Improve CKC core #601 (lburgazzoli)
- Updated the mvnd command on the readme #599 (orpiske)
- Camel-kafka-connector-catalog: Adding some more tests #596 (oscerd)
- Slack transforms #595 (oscerd)
- Rename all transformers, converters, aggregationStrategies to reflect the maning convention we have #593 (oscerd)
- Improve readme #591 (orpiske)
- Add converters, transforms and aggregationStrategies to catalog #589 (oscerd)
- Avoid usage of static for Camel Kafka Connector catalog #588 (apupier)
- Added GH actions to run the camel-master build using the Strimzi Next profile #587 (orpiske)
- Changes to documents - change version from 0.3.0-SNAPSHOT, give the right location of the properties file within docs/examples #586 (cunningt)
- Issue/563 #585 (valdar)
- JMS example: Added missing steps #584 (oscerd)
- Added new test for Azure Storage Blob sink #582 (orpiske)
- ISSUE-524 Create a source distribution module #577 (cunningt)
- ISSUE-146 Prevent the overwrite of existing classes unless they are @Generated annotated #576 (cunningt)
- Camel-Kafka-kafka-connector is back #575 (oscerd)
- 573 allow to add remove elements from catalog dynamically through api #574 (apupier)
- Add back AWS*-connectors #572 (oscerd)
- Improve Catalog and cleanup #571 (oscerd)
- github action: add trigger on workflow_dispatch #568 (lburgazzoli)
- GH actions: Fixed deploy action #567 (oscerd)
- Do not use the wrapper test client on the AWS v2 service classes #562 (orpiske)
- Have CamelKafkaConnectorCatalog working with bundled jar #554 (apupier)
- Catalog: Removed static modifier from getConnectorsModel #553 (oscerd)
- build: execute ci-build for pr/push to the camel-master branch #552 (lburgazzoli)
- Jenkinsfiles clean #551 (oscerd)
- Catalog: expose an API for consuming connectors catalog metadata and options #548 (oscerd)
- core: simplify kafka headers to camel exchange mapping #547 (lburgazzoli)
- source: better handling of headers of type Data #546 (lburgazzoli)
- Do not use the wrapper test client on the AWS service classes #545 (orpiske)
- core: cast from Byte[] to byte[] fails because of incompatible types #543 (lburgazzoli)
- core: add support for aggreation on source sinks #541 (lburgazzoli)
- Improve Catalog and cleanup #540 (oscerd)
- [core] use Endpoint instead of URI string to send exchnages using the producer template #538 (lburgazzoli)
- Catalog: Rename the json file to reflect the id and connectors.properties content #536 (oscerd)
- Improve core #535 (lburgazzoli)
- Clean up usages of org.junit.Assert #533 (mureinik)
- chore(build): merge GitHub workflow master-pr-build master-push-build #532 (lburgazzoli)
- Added build details using mvnd #531 (orpiske)
- Add a Maven Plugin to collect the connector descriptors for catalog purpose #530 (oscerd)
- chore(build): split build in multiple steps #528 (lburgazzoli)
- chore(build): use AdoptOpenJDK to set-up java #527 (lburgazzoli)
- [camel-main-support] Use BaseMainSupport instead of Main #526 (lburgazzoli)
- Create descriptors for source and sink connector for catalog purpose #525 (oscerd)
- camel-kafka-connector-model should have tooling pom as parent pom #521 (valdar)
- Added encoding to maven-resources-plugin to avoid warning #520 (oscerd)
- Fixed GH Actions with the new camel-kafka-connector-model #519 (oscerd)
- Move model classes CamelKafkaConnectorModel and CamelKafkaConnectorOp… #518 (oscerd)
- adding docs that explain the directory requirement under the plugins folder #517 (codexetreme)
- Added a camel-kafka-connector-catalog collecting all the JSON metadata #516 (oscerd)
- Generate a Json Metadata file for each connector #512 (oscerd)
- Opted the project in for HAcktoberfest 2020. #511 (valdar)
- Add an integration test for the archetype #510 (cunningt)
- [camel-main-support] Reordering props should not be required anymore #507 (oscerd)
- Removed folder added for error and regen docs #504 (oscerd)
- Throttles strimzi startup to prevent resource reuse errors #503 (orpiske)
- Rabbitmq itest #501 (valdar)
- Removed the Jenkinsfile deploy pipeline, we are now using gh action #496 (oscerd)
- Upgrade Maven Wrapper to 0.5.6 #495 (oscerd)
- Deploy on ASF Snapshot #493 (oscerd)
- Issue 490 #491 (oscerd)
- Fixes changelog to run only on master #488 (oscerd)
- Removed bean-validator kafka connector #483 (oscerd)
- Re-introduce camel-bean-kafka-connector #482 (oscerd)
- Bean connector removed #481 (oscerd)
- Added AWS S3 test using AWS v2 #480 (orpiske)
- Fix GH connection timeout issue #478 (orpiske)
- Fixes typos when an invalid instance type is provided #477 (orpiske)
- Implement the connection timeout work-around #476 (orpiske)
- Removed browse and class connector #475 (oscerd)
- Removed digitalocean connector #472 (oscerd)
- .asf.yaml: Enabled only rebase and squash button on PR #471 (oscerd)
- Replaced the use of kubectl with oc command. #468 (valdar)
- Updated opesnhift documentation to strimzi 0.19.0 and compatible with… #467 (valdar)
- Document update #464 (NiteshKoushik)
- Document Update #461 (NiteshKoushik)
- Document Update #460 (NiteshKoushik)
- Switch from Gitter to Zulip #459 (lburgazzoli)
- Support for topics.regex #458 (oscerd)
- Added 0.5.0 to the compatibility matrix #453 (oscerd)
- 0.5.0 docs #452 (oscerd)
- Updated SQS example #450 (oscerd)
camel-kafka-connector-0.4.4 (2020-10-10)
Fixed bugs:
- Azure blob sink does not put file in azure #270
Closed issues:
- source: better handling of headers of type Data #544
- Catalog: expose an API for consuming connectors catalog metadata and options #542
- Catalog: Rename the json file to reflect the id and connectors.properties content #534
- Add a Maven Plugin to collect the connector descriptors for catalog purpose #529
- Create descriptors for source and sink connector for catalog purpose #523
- Move model classes CamelKafkaConnectorModel and CamelKafkaConnectorOptionModel in their own module #515
- Copy all Json connectors metadata into a camel-kafka-connector-catalog #514
- Document build steps w/ mvnd #513
- Generator a JSON metadata file for each connector #508
- [camel-main-support] Use BaseMainSupport instead of Main #499
- [camel-main-support] Reordering props should not be required anymore #498
- Add an ASF deploy GH Action like other camel projects #492
- MongoDB Kafka Connector: In the docs add Json as base value converter #490
- Create an Infinispan example #486
- Create Minio connector examples #456
- Support topics.regex #454
- Define a default naming for converters, transforms and aggregation packages #439
- High CPU Usage with RabbitMQ Connector (polling interface implemented incorrectly?) #414
- How to have connector output JSON String? #398
- Question: Does Camel looks for IAM roles from Env variables #282
Merged pull requests:
- Added connector class on each connector documentation page #406 (oscerd)
- Removed wrong terminal output from example in archetype docs #395 (oscerd)
- Point to correct branch in gh workflows #385 (oscerd)
- Point to correct branch in github workflows #384 (oscerd)
- Camel 3.4.3 #382 (oscerd)
- Backport raw fixes #371 (oscerd)
- Make the camel-kafka-connector archetype use the parent POM #364 (oscerd)
- Fixed index adoc #353 (oscerd)
- Added missing connector in connectors pom #351 (oscerd)
- 0.4.1-SNAPSHOT #349 (oscerd)
- Pointing to 0.4.x on this branch for antora #348 (oscerd)
- Release 0.4.0 #347 (oscerd)
camel-kafka-connector-0.5.0 (2020-09-09)
Implemented enhancements:
- Add the connector class to use in the documentation of each connector #321
- Support multiple topics for connector configuration #197
- Generate a catalog of supported connectors #141
Fixed bugs:
Closed issues:
- Unreleased Resource: Database #436
- Create an NSQ example #429
- Archetype: Add a parameter to the archetype generator to be able to specify what connector we want to extend #419
- IMPROVEMENT REQUEST: Add a transformer mode to the connectors to make lightweight edits to the messages while they are being produced/consumed #410
- aws2-S3-connector: (gzip/zip) compression with sink #387
- Discussion: troubleshooting documentation? #381
- Bump to Camel 3.4.3 #379
- Documentation: SJMS2 connector is incompatible with activemq-all #378
- Unclean startup causes an NPE on shutdown #376
- Make the camel-kafka-connector archetype use the parent POM #362
- Exception on endpoint being treated as a polling consumer before createPollingConsumer is called. #361
- Add a Nats connector examples in camel-kafka-connector-examples repo #359
- Add a compatibility matrix related to camel version in docs #344
- aws2S3connector: moveAfterRead true bucket not created #339
- CamelAwssqsSinkConnector does not work when specifying AWS credentials in camel.sink.endpoint #319
- Create a Kinesis Firehose Connector example #318
- Nullpointer exception at org.apache.camel.component.aws2.s3.AWS2S3Producer.processSingleOp #299
- Add Aggregate integration test #291
- Enable testRetrieveFromCassandraWithCustomStrategy on CamelSourceCassandraITCase #288
Merged pull requests:
- Fix potentially unreleased DB resources in test code #437 (orpiske)
- Automatic changelog: Run it just one time during the night #435 (oscerd)
- Run the changelog automatic updated every hour #434 (oscerd)
- Update try-it-out-on-openshift-with-strimzi.adoc with latest AWS S3 connector config #433 (smccarthy-ie)
- Pr Build and push build needs to point to master #432 (oscerd)
- adding a key transformer to the AWS2-SQS connector so that the CamelH… #431 (codexetreme)
- Proposed fix for issue #414 #428 (orpiske)
- Camel 3.5.0 #427 (oscerd)
- Docs: Updated archetypes docs #422 (oscerd)
- Archetype: Add a parameter to the archetype generator to be able to s… #421 (oscerd)
- Fix a minor typo #420 (oscerd)
- Removed deploy phase from jenkinsfile, we already have the daily snap… #418 (oscerd)
- Remove deploy phase from Jenkinsfile, we have the daily snapshot depl… #417 (oscerd)
- [Github Actions] Periodic Sync Camel-kafka-connector camel-master Branch #416 (github-actions[bot])
- Activemq-all note for SJMS2 connector #415 (oscerd)
- Rework the testing documentation and adds test writing details #413 (orpiske)
- Added new test for Azure Storage Queue sink #412 (orpiske)
- Support Multiple topics on Source Connector #411 (oscerd)
- Added connector class on each connector documentation page #405 (oscerd)
- Added a pipeline for deploying on daily basis #404 (oscerd)
- #389 - Fix doc- Kubernetes command #401 (rogeriob2br)
- Fix mongodb test #396 (unsortedhashsets)
- Removed wrong terminal output from example in archetype docs #394 (oscerd)
- Kafka-clients is not a test dependency #393 (oscerd)
- Added automatic-sync gh action for camel-kafka-connector on camel-mas… #392 (oscerd)
- Adds basic aggregation test (github issue #291) #388 (orpiske)
- Fix flaky syslog test #386 (orpiske)
- Added a simple troubleshooting guide #383 (orpiske)
- Upgrade to camel 3.4.3 #380 (oscerd)
- Prevent NPEs on shutdown when critical errors occur #377 (orpiske)
- Fixed incorrect number of log arguments in S3 exception handling #375 (orpiske)
- Defer topic deletion #374 (orpiske)
- Fixes for edge cases #373 (orpiske)
- Added missing fromUrl to the log message #372 (orpiske)
- Removes debugging message #370 (orpiske)
- Removing backport gh action. It doesn't work. #369 (oscerd)
- Minor AWS tests cleanups #368 (orpiske)
- Building endpoint uris should for secret options automatic use RAW() … #366 (davsclaus)
- Cutting down connectors #365 (oscerd)
- Make the camel-kafka-connector archetype use the parent POM #363 (oscerd)
- AWS SDK v2 integration tests: Kinesis #358 (orpiske)
- Use latest Strimzi's docker images #357 (oscerd)
- Fixed camel compatibility matrix table #356 (oscerd)
- Added a camel-compatibility matrix page #355 (oscerd)
- Upgrade Archetype docs #354 (oscerd)
- Fixed index adoc #352 (oscerd)
- Added missing connector in connectors pom #350 (oscerd)
- Release 0.4.0 #346 (oscerd)
- AWS Kinesis test fixes when in remote mode #345 (orpiske)
camel-kafka-connector-0.4.0 (2020-07-29)
Implemented enhancements:
- Being able to inject an aggregator in a sink connector #274
- In case of Sink we need to use toD instead of to #252
- Upgrade to Kafka 2.5.0 #249
- Improve integration test support when component dependencies are present #211
- Support both marshal and unmarshal in source and sinks #194
- camel-kafka-connector-generator-maven-plugin: implement a component exclusion mechanism #148
Fixed bugs:
- BigDecimal values are not handled correctly in Headers serialization and deserialization #325
- Camel HDFS: does not work due to dependencies conflicts #263
- NullPointerException during shutdown when using Salesforce component #245
Closed issues:
- Camel-Elasticsearch Connector not working on OpenShift #342
- aws2S3connector connected to minio ClassCastException #338
- Add documentation for archetype #333
- Add an archetype to be able to extend the existing connectors with converters/aggregators/transformations/pojo etc. #329
- The committed block count cannot exceed the maximum limit of 50,000 blocks. #324
- Upgrade to Camel 3.4.2 once released #322
- CamelAwssqsSinkConnector is leaking AWS credentials into Kafka Connect log #320
- How install camel-jira-kafka-connector #315
- From S3 to kafka, when using Idempotent filter, Do we still fetch S3 file content ? #314
- How to break messages when ingesting into kafka #313
- In S3 source connector, how to fetch only new files ? #311
- CAMEL-15063 work-around may be removed #310
- Add an aggregation page in docs #303
- Outdated camel-dependencies version? #297
- Aggregator support for completionTimeout too #290
- Upgrade to Camel 3.4.0 LTS version #283
- Camel-MongoDB Kafka connector: example with sink connector #212
Merged pull requests:
- Issue/194 #341 (valdar)
- Re-enable a Cassandra test disabled due to CAMEL-15219 #337 (orpiske)
- Add CORE protocol support to SJMS2 connector #336 (fvaleri)
- Document how to run camel-kafka-connector on Kubernetes. #335 (fvaleri)
- Archetypes docs #334 (oscerd)
- Added Aggregation documentation #332 (oscerd)
- Introducing a camel-kafka-connector-extensible archetype for adding b… #330 (oscerd)
- Adds a new manual integration test for Slack source #328 (orpiske)
- Bump Camel to version 3.4.2 #327 (oscerd)
- Issue/325 #326 (valdar)
- Added additional explanation about testing #317 (orpiske)
- Added tests for JDBC sink #316 (orpiske)
- Reverts the work-around for CAMEL-15063 #312 (orpiske)
- Fix HDFS tests with Camel 3.4 (related to issue #263) #309 (orpiske)
- Fixes AWS test cases when running with remote AWS services #308 (orpiske)
- Avoid logging the autoconfiguration summary from CamelMain #307 (oscerd)
- Upgrade Kafka to version 2.5.0 #306 (oscerd)
- Fix Typo in CamelTypeConverterTransform #304 (oscerd)
- Added Aggregation timeout #301 (oscerd)
- Fixes camel-dependencies to point to 3.4.0 #298 (oscerd)
- ToD support #296 (oscerd)
- Add tests for MongoDB #295 (orpiske)
- Temporarily disable HDFS tests due to issue #263 #294 (orpiske)
- Bump to Camel 3.4.0 #293 (oscerd)
- Updated the packages docs page #292 (oscerd)
- Aggregate Support #289 (oscerd)
- Cassandra test improvements #286 (orpiske)
- Backport #285 (oscerd)
- Use release 0.3.0 as lastReleasedVersion #284 (oscerd)
- Fixed component exclusion in combination with filter #281 (oscerd)
- Component exclusion #278 (oscerd)
- Added tests for Camel HDFS Sink #277 (orpiske)
camel-kafka-connector-0.3.0 (2020-06-17)
Implemented enhancements:
- Use camel-depencencies to import versions of common libraries like Jakson, qpid, log4j etc. #241
- Autogenerate and example config file for each connector #220
- S3 source connector delete files from source bucket #97
- Create example and itest for camel-syslog #77
Fixed bugs:
- Camel-elasticsearch-rest-kafka-connector throws java.lang.NoClassDefFoundError: org/apache/logging/log4j/LogManager #259
- Wrong signature of autogenerated method
public static ConfigDef conf\(Map\<String, String\> parsedConfig\)
of eachCamel\*ConnectorConfig
#221 - Possible problems in CamelSinkAWSSQSITCase tests #215
Closed issues:
- Question: How to provide aws role:arn value to authenticate S3 #267
- Add CamelAMQP source and sink example properties #264
- Add download links to the connectors list page #261
- AWS S3: bucket name not resolved when using URL configuration #260
- Caused by: java.lang.NoClassDefFoundError: Could not initialize class org.apache.camel.kafkaconnector.CamelSinkConnectorConfig #251
- Camel AWS2-S3: Add the same converters and transforms we have for AWS-S3 connector #250
- pls #248
- Connectors doc generation shuld be moved from
core
toconnectors
module #226 - Investigate why syslog documentation result in a missing link #225
- CamelSinkTask Properties need to be cleaned up before going ahead #224
- CamelSinkTask headers must be cleaned before sending them ahead #223
- Updater the readme of autogenerated connectors doc page #219
- Bump to Camel 3.3.0 #217
Merged pull requests:
- Fix a javadoc issue. #276 (valdar)
- fix #259: Camel-elasticsearch-rest-kafka-connector throws java.lang.N… #275 (valdar)
- Throw ConnectException due to failed exchanges #273 (omarsmak)
- Issue/260 #272 (valdar)
- Test modularization cleanups #271 (orpiske)
- AWS2-S3 connector: Added the same set of converters/transformers we h… #268 (oscerd)
- Docs download link #266 (oscerd)
- Add AMQP examples for source and sink #265 (rgannu)
- Split the tests in modules per service #262 (orpiske)
- chore(pgp): update pgp key for Nicola Ferraro #256 (nicolaferraro)
- Updated try-it-out-on-openshift-with-strimzi.adoc #255 (valdar)
- Adds integration tests for Salesforce #247 (orpiske)
- Fixed quickstarts docs #246 (oscerd)
- Sf fix #244 (valdar)
- Use camel-depencencies to import versions of common libraries like Ja… #243 (oscerd)
- Fix CamelSinkAWSSQSITCase unreliability with blocking initialization #242 (orpiske)
- Bump Log4j to version 2.13.3 #240 (oscerd)
- Example prop autogen #239 (valdar)
- Bump Jackson to version 2.10.4 #238 (oscerd)
- Bump Qpid JMS client to version 0.51.0 #237 (oscerd)
- Upgrade Strimzi images to 0.18.0-kafka-2.4.1 #236 (oscerd)
- CamelSinkTask Properties need to be cleaned up before going ahead #235 (oscerd)
- CamelSinkTask headers must be cleaned before sending them ahead #232 (oscerd)
- Bump to Camel 3.3.0 #231 (oscerd)
- Version bump to Camel 3.3.0 #230 (orpiske)
- Connectors doc generation shuld be moved from
core
toconnectors
… #229 (oscerd) - Syslog docs #227 (oscerd)
- Fixed con cong autogen #222 (valdar)
- Remove core from test plugin path #218 (orpiske)
- Sink test refactoring #216 (fvaleri)
- Add contentLogLevel task property #193 (fvaleri)
camel-kafka-connector-0.2.0 (2020-05-17)
Implemented enhancements:
- Avoid Thread.sleep in test, use Awaitility FTW #186
- make the topics property consistent between source and sink connectors #175
- Produce an assembly artifact containing all the released artifacts #165
- Create and ad hoc connector for syslog #145
- Take in to account endpoint path options order into connector code generation #144
Fixed bugs:
- Ordering of endpoint path options is not taken in account #143
Closed issues:
- Add connector dependencies in distribution package #203
- Switch to Camel 3.2.0 #199
- Cannot apply transforms to Telegram Source Connector #188
- Connectors doc: Show up only the priority in the table column #182
- Add an index for connectors in docs #169
- Autogenerate documentation for sink and source connectors #167
- Provided dependencies management #158
- Checkstyle missing unused imports? #156
- Generate a table with supported connectors #142
- Test coverage: springboot autoconfigurations vs kafka-connect configuration format #132
- Release 0.1.0 #130
Merged pull requests:
- Syslog connector #214 (valdar)
- Bump Testcontainers to version 1.14.2 #213 (oscerd)
- Removes usage of fixed hostnames in integration tests #210 (orpiske)
- Grammar fixes in basic concepts adoc #209 (oscerd)
- chore: rename poorly named variable in test code #208 (orpiske)
- Re-enable Cassandra test using properties #207 (orpiske)
- Bump to Camel 3.2.0 #206 (oscerd)
- Improved CamelSourceTaskTest #205 (fvaleri)
- Removed Thread.seep(...) in unit tests in order to avoid possible sou… #204 (valdar)
- Flakey tests #200 (valdar)
- Generate a table with supported connectors #198 (oscerd)
- Make the topics property consistent between source and sink connectors #196 (oscerd)
- Produce an assembly artifact containing all the released artifacts #195 (oscerd)
- Switched to use RuntimeCatalog.asEndpointUri method to construct the … #192 (valdar)
- Connectors doc: Show up only the priority in the table column #190 (oscerd)
- Added test on different component properties formats fix #132 #187 (valdar)
- Code cleanup #184 (fvaleri)
- Lets try to use a shortname of 50 for connectors options #181 (oscerd)
- Camel-kafka-generator-maven-plugin: Use the Strings class from toolin… #180 (oscerd)
- Introduce the shortName method for option name #179 (oscerd)
- Added a little example of AWS-S3 source connector #177 (oscerd)
- Docs generation now contains also the number of options available per connectors #176 (oscerd)
- Adds a manual test for the Camel Slack sink connector #174 (orpiske)
- Special case for coap+tcp and coaps+tcp #173 (oscerd)
- Regen docs #172 (oscerd)
- Regen docs pages by adding title, so Antora will be happy #171 (oscerd)
- Add an index for docs #170 (oscerd)
- Docs sink source #168 (oscerd)
- Pom fixes #161 (valdar)
- Added a building section in the docs #160 (oscerd)
- Fixes a couple of style violations and warnings on test code #157 (orpiske)
- Additional tests for different configuration styles #155 (orpiske)
- Release0.1.0 #154 (valdar)
- Fixed github action issue with never released builts. #153 (valdar)
- Upgrade testcontainers to version 1.14.1 #152 (oscerd)
camel-kafka-connector-0.1.0 (2020-04-25)
Implemented enhancements:
- Migrating to Junit 5 #74
- Replace
confluentinc/cp-kafka
image with an upstream version #43 - Test code cleanups: embedded connect runtime improvements #24
- Add a CI job for PR #19
- Support Map and List as Headers #18
- Find a way to manage dependencies #15
- Unclean shutdown causing lots of warning messages in the logs #13
Fixed bugs:
- Unable to initialize REST resources in tests #120
- ERROR - Plugin class loader for connector: was not found. #118
- Flaky test: CamelSinkCassandraITCase #67
- Integrations tests fails if confluentinc/cp-kafka:5.2.1 has not been pulled #25
Closed issues:
- Create a documentation index and reflect it on the website #136
- Documentation: Add instructions on how to use the packaged connectors in Kafka Connect #134
- Generate documentation to be integrated with Antora and camel website #128
- Define how to package the connectors #127
- Upgrade to Kafka 2.4.1 #105
- Not able to add resource file #104
- Not able to run aws s3 source connector #95
- Bump Kafka to version 2.4.0 #69
- Unstable test: CamelSourceTaskTest.testSourcePollingTimeout #55
- Add a sink and sources examples with camel-cassandraql #35
- Better support for value Schema in the SourceTask #32
- run integration test insided github actions? #31
- INFRA - Turn off mail noise to Camel @dev mailing list #30
- Allow the user to set the key of the SourceRecord explicitly #20
- support camel type converters #16
- The camel-kafka-connector artifacts pulls number of dependencies #9
- Add Release profile #7
Merged pull requests:
- Moved from camel-core to camel-core-engine as a dependecnies. #140 (valdar)
- Added gpg key for valdar. #139 (valdar)
- Test code fixes for the auto-generated connectors #138 (orpiske)
- Misc #133 (valdar)
- Packaging the connectors as zip and tar.gz #131 (oscerd)
- Auto gen #129 (valdar)
- Upgrade Testcontainers to version 1.14.0 #126 (oscerd)
- Upgrade Junit Jupiter to version 5.6.2 #125 (oscerd)
- Replaces our own connect runtime implementation with the embedded one from Kafka #124 (orpiske)
- Removed unused class HTTPEchoService #123 (orpiske)
- Fixes a misplaced log error message flooding the logs w/ invalid errors #122 (orpiske)
- Sidebar menu Tidy up name -issue 14567 #121 (rimshach)
- Bump Qpid JMS to version 0.50.0 #119 (oscerd)
- Improve documentation for the about section #116 (AemieJ)
- Binded itests to test phase to better accommodate github actions disk… #115 (valdar)
- Auto gen #114 (valdar)
- Added a Jenkinsfile for JDK11 #113 (oscerd)
- Added a Jenkinsfile for JDK8 and being able to deploy automatically #112 (oscerd)
- Pointing to ASF Snapshot and use the apache Parent #111 (oscerd)
- Bump Junit Jupiter to version 5.6.1 #110 (oscerd)
- Bump ActiveMQ to version 5.15.12 #109 (oscerd)
- Avoid building all the code for sourcecheck verification #108 (orpiske)
- Added support for remote AWS testing #107 (orpiske)
- Upgrade Kafka to version 2.4.1 - fixes #105 #106 (oscerd)
- Upgrade Jackson to version 2.10.3 #103 (oscerd)
- Auto gen step 2: generated connectors structure and dependencies. #102 (valdar)
- Ensure that local containers used during tests are properly shutdown after the test is completed #101 (orpiske)
- Upgrade test containers #100 (orpiske)
- Bump to Camel 3.1.0 #99 (oscerd)
- Little updates to docs #98 (oscerd)
- Fix missing licenses #94 (orpiske)
- Adds support for running tests against external ElasticSearch instances #93 (orpiske)
- Adds support for running tests against external Cassandra instances #92 (orpiske)
- Small adjustment to sourcechecks. #91 (valdar)
- Fixed README.adoc links after Antora init. #90 (valdar)
- fix(docs): replace anchor syntax for placeholder #89 (zregvart)
- chore(docs): cleanup wording and syntax #88 (zregvart)
- feat(docs): setup Antora #87 (zregvart)
- [SECURITY] Use HTTPS to resolve dependencies in Maven Build #86 (JLLeitschuh)
- First step for issue #15 #85 (valdar)
- Upgrade Qpid JMS client to version 0.48.0 #84 (oscerd)
- Added support for using an external JMS broker #83 (orpiske)
- Added support for loading test properties from a properties file #82 (orpiske)
- Bump TestContainers to version 1.12.5 #81 (oscerd)
- Bump to Camel 3.0.1 #80 (oscerd)
- Upgrade Junit to version 5.6.0 #79 (oscerd)
- Upgrade strimzi images to the latest version #78 (orpiske)
- Migrates all the test cases to Junit 5 #75 (orpiske)
- Added sourcecheck to github actions, added master push github action … #73 (valdar)
- Updated integration test image to kafka 2.4 #72 (valdar)
- Fix issue #67: Flaky test: CamelSinkCassandraITCase #71 (orpiske)
- Bump Kafka to version 2.4.0 #70 (oscerd)
- Upgrade ActiveMQ to version 5.15.11 #68 (oscerd)
- Added support for testing the Kafka service using Strimzi #66 (valdar)
- Auto gen #65 (valdar)
- Add integration test for Cassandra CQL #64 (orpiske)
- Bump Jackson to version 2.10.2 #63 (oscerd)
- Use artifactId instead of project.name to build colon-less distro paths #62 (ppalaga)
- Bump Junit to version 4.13 #61 (oscerd)
- Should use year instead of week year #60 (orpiske)
- Property placeholders #59 (oscerd)
- Relaxing condition to accomodate some timeout glitches, fix #55 #58 (valdar)
- Convert the embeddable Kafka Connect runner to a JUnit rule #57 (orpiske)
- Stop removing JMS-related containers after they are built #56 (orpiske)
- Upgrade test containers to the latest version #54 (orpiske)
- Fixes #52 (valdar)
- Rearrange date and time #51 (omarsmak)
- Fixed missing license #50 (orpiske)
- fix checkstyle violation #49 (omarsmak)
- Add checkstyle profile #48 (omarsmak)
- CassandraQL sink connector example #47 (oscerd)
- Cassandraql source example #46 (oscerd)
- Added a gitter badge for our chat #45 (oscerd)
- Fix Kafka instance type should read from the property not from the system env #42 (orpiske)
- Adds an example configuration for ElasticSearch Index #41 (orpiske)
- Allow to configure a source record key from camel message header key #39 (omarsmak)
- Replaces artemis with qpid-dispatch router #38 (orpiske)
- Infer the suitable schema in the SourceTask #37 (omarsmak)
- Adds support for ElasticSearch index operation + tests #36 (orpiske)
- Support camel type converter #34 (omarsmak)
- Send S3ObjectSerializer I/O error to the LOG instead of stdout #33 (orpiske)
- Support using an external Kafka for the tests #29 (orpiske)
- Camel-AWS S3 example: Use a Transformation instead of a converter #28 (oscerd)
- Map list as headers #26 (oscerd)
- Setting up POM as ASF standard #14 (oscerd)
- Reduce log default log verbosity #12 (orpiske)
- Cleanup the AWS SQS Sink test #11 (orpiske)
- Mark camel components as provided dependencies #10 (jerrinot)
- Added release profile for the beginning #8 (oscerd)
- Fix Sink File test #6 (orpiske)
- chore: update maven to v3.6.3 #5 (lburgazzoli)
- chore(build): set up github actions #4 (lburgazzoli)
* This Changelog was automatically generated by github_changelog_generator