Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* support kinesis firehose, unify kinesis config, add better metric support * clean up warnings * fix registerGauge declaration and change deprecated setDeliverGuarantee method call * added test for firehose config * initial version * compileable * close to testable * writing tests * Adding parallelism to sink * got basic test working * fix bug in test * improve tests * support consuming from multiple streams * add tests * reformat/optimize imports * refactored several things * fix typo * refactor addSink() method in cassandra sink * try to fix cluster builder serialization issues * refactor closures in JdbcSink and CassandraSink * fix type and reformat * turn off debugging in tests * updates * updates * add print sink and iceberg tests * refactor iceberg source * fix iceberg tests * update iceberg version to 1.2.0 * add aws.region setting for tests * remove aws.region setting for tests * set aws creds for iceberg test * update iceberg direct access test * try to fix test on travis * remove testcontainers debug from tests * fixed test * remove duplicative trait extension * fix id64 test * add simple stream node inspection for testing * fix confluent avro deserialization * optimize imports/scalafmt * reenable ConfluentAvroRegistryKafkaRecordDeserializationSchemaTest * fix tests --------- Co-authored-by: Robert Lyons <nextdude@gmail.com> Co-authored-by: LizaMo <lmorozov@mdsol.com>
- Loading branch information
1 parent
284a4b1
commit 0461083
Showing
88 changed files
with
3,969 additions
and
1,549 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.