Changelog
Full Changelog
Closed issues:
- Consume JSON string for Cassandra sink connector #1487
Merged pull requests:
Full Changelog
Closed issues:
- camel-https-kafka-connector support for multiple HTTPS endpoints #1504
- Salesforce sink update #1500
- Unable to set
password for camel-sjms2-kafka-connector #1491 - Upgrade to Camel-Kamelets 0.8.1 #1372
Full Changelog
Closed issues:
- Upgrade Camel to version 3.19.0 and Kameles 0.10.0 #1481
- SCP / SFTP connectors do not allow setting private keys for SSH authentication #1470
- FTP/SFTP sink connectors do not allow setting binary mode for transferring files #1469
- Upgrade to Camel 3.18.2 and Camel-Kamelets-catalog 0.9.1 #1449
- camel-rabbitmq-source-kafka-connector: Unable to specify vhost #1442
- Azure authentication erros on 3.18.x #1440
- Release 1.1.0 #1373
- Re-enable SSH Sink Test #1295
- Define the excluded Components list #279
Full Changelog
Closed issues:
- CamelSinkTask throws NPE on schemeless header #1447
Full Changelog
Closed issues:
- Proposal: Align released version to the underline Camel release #1421
- AWS Kinesis source connector: error #1391
- Payload is base64 encoded CAMEL-GOOGLE-PUBSUB-SOURCE-KAFKA-CONNECTOR SOURCE 1.0.0 #1390
- ignoreFileNotFoundOrPermissionError on camel-sftp-source 1.0.x #1385
- Upgrade to Camel-Kamelets 0.8.0 and Camel 3.16.0 #1360
- camel kafka connector - s3 Sink #1357
- camel-aws-s3-sink-kafka-connector is showing class error and not pushing data to s3 #1347
- camel-salesforce cosumer: message id not in sequence for platform events #1343
- SalesforceConsumer : java.lang.IllegalStateException: Queue full #1342
- Dead loop for connector state #1341
Full Changelog
Fixed bugs:
- CameHeader value is wrongly interpreted as BigDecimal and causes ClassCastException #1332
Closed issues:
- UNAUTHENTICATED: Credentials require channel with PRIVACY_AND_INTEGRITY security level. Observed security level: NONE #1337
- Use SNS Aws2 connector with AWS Default Credential Provider #1335
camel-kafka-connector-catalog version 1.0.0 is missing descriptor/ direcotry #1333- UNAUTHENTICATED: Credentials require channel with PRIVACY_AND_INTEGRITY security level. Observed security level: NONE #1330
- Connectors Webpage Links to Older Version #1326
- Do Camel Kafka Connectors support “Dead Letter Queue” and “Connect Reporter” features of Kafka Connect? #1323
- Pubsub kafka connector error: java.net.UnknownHostException: pubsub.googleapis.com: Name or service not known #1319
- camel-salesforce-kafka-connector-0.11.0 There is an Exception during HANDSHAKE: Invalid protocol null #1304
- Upgrade to Kamelets 0.6.0 #1303
- Upgrade to Camel 3.14.0 #1302
- [Security] Workflow daily-java-next.yml is using vulnerable action actions/checkout #1301
- How can I capture the HTTP response from camel-http-kafka-connector (sink)? #1296
Full Changelog
Fixed bugs:
- Error with Syslog Source Connector #665
Closed issues:
- Update Antora usage #1308
- CamelAws2s3SinkConnector not processing kafka null (deleted) messages #1300
- Fails to create CamelAws2sqsSourceConnector #1293
- Problem with line breaks kafka-hdfs sink connector #1291
- The pre-release salesforce source connector, how does the query field work? #1289
- Cannot findr camel-salesforce-source-kafka-connector in maven repository #1284
- Using kinesis sink with STS assumeRole credentials? #1272
- Salesforce Camel Kafka Source Connector not converting to JSON #1271
- java.lang.NullPointerException in kinesis sink connector if headers not present #1268
- AWS SQS Source Message Delete #1266
- Modular packaging of connectors? #1264
- Bearer Token with HTTP sink? #1255
- One file per message (kafka hdfs sink connector) #1222
- Run slow tests on Apache CI #786
Full Changelog
Closed issues:
- how to convert csv to json using unmarshal/marshal #1253
- Bump to Strimzi 0.25.0 #1248
- Configurable parameters in AWS2-s3 Kafka source connector #1247
- Using a Kafka Consumer with Idempotency enabled Kafka consume #1245
- Bump to Camel 3.11.1 #1243
- Endpoint doesn't get resolved when using Camel Splunk HEC Kafka connector #1241
- Upgrade to Camel 3.11.0 #1237
- idempotency support in Kafka AWS s3 source connector #1236
- aws2-s3 prefix not working with Kafka source connector #1235
- Is it possible to attach Custom Processor to existing Connector? #1228
- Access headers on S3 Source connector #1224
- Jira source connector only sourcing new issues #1221
- Bump to Strimzi Operator 0.24.0 #1219
- Improve documentation about limitations of special chars in the file connector #1218
- Java bean error when using aws2-s3-source connector #1217
- AWSS2-S3-Kafka connector sink returns 403 with bucket and object not public #1216
- Issue with camel-google-pubsub-kafka-connector sink configuration #1209
- CamelFileSink Connector appendChars = \n not working #1208
- aws2s3 sink connector cannot access kafka headers #1200
- Missing kafkaconnector parent pom artifact for version 0.10.0 #1190
- camel-minio-kafka-connector can't split minio file #1124
Full Changelog
Closed issues:
- aws2s3 source connector split file into several messages #1196
- camel-elasticsearch-rest-kafka-connector indexId #1192
- CAMEL-AWS-KINESIS-KAFKA-CONNECTOR SOURCE CONFIGURATION #1186
- Release 0.10.0 #1184
- Bump to Camel 3.10.0 #1183
- camel-salesforce-kafka-connector missing dependency library #1114
- Improve documentation TOC #389
Full Changelog
Implemented enhancements:
- Verify that sha512 files are correctly published during next release #162
Fixed bugs:
- HTTPS-sink-connector duplicates protocol #1077
- MongoDB tests failing with Camel master #974
Closed issues:
- Salesforce Sink Connector does not honour
offset.flush.interval.ms #1181 - Upgrade to Strimzi 0.23.0 #1173
- Camel Rest Kafka Connector - Issue with Kubernetes Rest connector. #1171
- Upgrade to Strimzi 0.23.0 RC #1166
- AWS SNS seems to be broken with Camel 3.9 and above #1156
- Jackson conflicts causing Azure Storage Blob tests to fail #1147
- Upgrade to Kafka 2.8.0 #1145
- example of a sql source connector url pattern #1144
- Upstream CI failures #1143
- Align master to latest camel snapshot #1133
- Connector Kafka Idempotency Crash Resilience #1128
- Release 0.9.0 #1127
- NetworkUtils should be able to hold a free port for later usage #1109
- Google pub/sub: endpoint option cannot be set #1086
- Missing message key on outbound using Camel Kafka KafkaConnector #988
- Question: S3 source connector pulls duplicate data when task.max > 1 #959
- add itests for camel-cxf-kafka-connector #873
- SJMS2 connector fails with qpid JmsConnectionFactory #751
Full Changelog
Fixed bugs:
- Camel-Netty-* connectors are not working #924
Closed issues:
- Upgrade Strimzi to version 0.22.1 #1117
- camel-mongodb-kafka-connector produce message format error #1113
- aws2 s3 source connector ClassCastException for value.conver #1107
- Upgrade Strimzi to version 0.22.0 #1105
- Release 0.7.3 #1095
Full Changelog
Fixed bugs:
- Prevent Kafka Connect from leaking passwords and sensitive data #1050
- Convert NettyChannelBufferStreamCache from NettyHttpSource not converted to string #969
Closed issues:
- netty-http sink itests - mock web server out of test code into JUnit 5 extension #1085
camel.source.endpoint.sync issue in CamelInfinispanSourceConnector in 0.8.0 #1068- ITests don't work when a test class is specified with
-Dtest=... #1062 - The count of transforms, converter and aggregation strategy seems to be broken for docs #1057
- Add SMT for GenericFile of Camel-file-kafka-connector #1047
- Add itests for camel-kafka-netty*-connectors #1036
- Grab topics using regex and put in S3 by topic name #1020
- How to set Map property via the kafka connector configuration #323
Full Changelog
Implemented enhancements:
- Camel components secret options are showed in logs #159
Fixed bugs:
- Azure storage queue failing on Camel Master #976
- SJMS2 Startup test failing on Camel Master #975
- Add tests to camel-kafka-connector-generator-maven-plugin #166
Closed issues:
- Website: connectors' list formatting problems #1041
- Generate just one connector package: .zip or .tar.gz #1030
- Azure storage blob failing on camel-master #997
- Consistent failures in GH tests #990
- Release 0.7.2 once Camel 3.7.2 will be released #978
- Add removeHeaders documentation #903
- Add test for AWS 2 SNS #700
- Add an example of FHIR connector's usage #402
- aws2S3connector: camel.source.endpoint.runLoggingLevel=TRACE no trace log #340
- Add a release notes page in docs #302
Full Changelog
Implemented enhancements:
- camel-kafka-connector-generator-maven-plugin: optionally delete submodules not in catalog #149
Fixed bugs:
- Java 14 support: gmavenplus-plugin likely not compatible #910
Closed issues:
- camel.source.contentLogLevel config not honored in source connectors #980
- Improve description of connector #979
- CamelKafkaConnectMain is showing sensitive information in summary #973
- Camel-master: Let's change the gh action to be triggered when a push on master has been done #939
- Add a map Camel Headers to Kafka headers option to make the behavior configurable #923
- Add a map Camel Properties to Kafka headers option to make the behavior configurable #922
- Java 14 support #913
- create a toHeader SMT #902
- Upgrade to Camel 3.7.1 the 0.7.x branch and release #872
- Camel-Master: SJMS2 it test is failing #844
- Support camel dataformat configuration for marshaller/unmarshaller #816
- Create a Twitter timeline example #640
- Introduce Error Handling Options possibilities #407
Full Changelog
Implemented enhancements:
- Produce a download/release page #163
Fixed bugs:
- Error reporting configuration incorrectly handled #835
Closed issues:
- Camel-Cron connector: We need to add at least camel-quartz as dependency #908
- Add a column to compatibility matrix about Kafka version #896
- Bump to Strimzi 0.21.1 #894
- Bump Apicurio Registry to 1.3.2.Final #889
- Modify the Github Actions configuration to allow archiving test logs #882
- HDFS tests running suspiciously flaky on Github actions #879
- Couchbase dependency missing? #878
- Bump to Strimzi 0.21.0 #876
- Bump to Kafka 2.7.0 #875
- [Question] liveness and readiness probes example for camel-kafka-connector #874
- AWS2-Kinesis: Add examples #866
- AWS2-Kinesis connector: Add a transformation to extract only the data from a source stream #857
- Github source connector: Add some transforms to deal with the different possible events #853
- [Question] How to process avro message in S3 connector #843
- Remove changelog gh action #842
- Support Parquet input Files using HDFS (compressed or not compressed) #840
- Add Github examples #825
- Add JDBC examples #824
- Add Mongodb examples #823
- Investigate usage of NO_DEFAULT_VALUE instead of null for properties #821
- Reading data from AMQP protocal using Strimzi kafka connector #817
- Date templating not working in version 0.6.0 #812
- Camel-AWS2-S3 connector: Add out of the box specific Aggregation Strategies #784
- using aws2-s3 source and sink to move files between buckets #762
- Add Braintree examples #628
- Create example for Couchbase connector #597
- Create a Google calendar example #424
Full Changelog
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
Full Changelog
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
Full Changelog
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)
- Updated SQS example #449 (oscerd)
- Update AWS SNS example #448 (oscerd)
- Updated the AWS S3 example #447 (oscerd)
- Updated the Cassandra example #446 (oscerd)
- Cut down the connectors number #445 (oscerd)
- Transformers package renaming #444 (oscerd)
- Define a default naming for converters, transforms and aggregation packages #443 (oscerd)
- Remove useless connector #441 (oscerd)
- AWS SQS tests w/ SDK v2 #438 (orpiske)
Full Changelog
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
Full Changelog
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:
- flaky syslog integration test #367
- UnitOfWork.done() needs to be called on Polled exchanges #202
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:
Full Changelog
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
Full Changelog
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 each Camel*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 to connectors 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
Full Changelog
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)
- 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)
- Adding Keys, Notice and License files #3 (oscerd)
- First commit #1 (oscerd)
Full Changelog
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
* This Changelog was automatically generated by github_changelog_generator