epiphanous / flinkrunner / 761

58%

master: 33%

push

travis-ci-com

Add Iceberg support (#68)

* 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>

540 of 540 new or added lines in 47 files covered. (100.0%)

1568 of 2690 relevant lines covered (58.29%)

0.58 hits per line