v0.2.0

This patch introduces new S3 source connectors for different formats:

• Text (CSV, JSON)
• Parquet

Features

• No size limit for single object / file
• Tunable batch size for latency and throughput
• Asynchronous file discovery
• Support both UTF-16 and UTF-8 encoding
• S3 Endpoints: AWS, NetApp ONTAP, StorageGRID

Contributors

• @niluka-insta made their contribution in #18
• @zheguang made their contribution in #20

IAM role support for S3 connector

implement IAM role support for S3 connector (#9)

* implement IAM role support for S3 connector

S3 connector IAM role support test

0.1.4-test

let assume role session duration to be set as default 15 minutes

New patch for Kafka 2.5.1

bump guava version (#2)

* Bump Kafka to 2.5.1

* Revert "Bump Kafka to 2.5.1"

This reverts commit 01ab6704206fd23752b5478acaa056693f0291c3.

* Bump to Kafka 2.5.1

* update version number

* Update distribution version

* remove dependency from parent pom

* update parent version in children pom

* Fix wrong k version number

* bump distribution xml version

* bump guava to 24.1.1; change error handling

* use getCause instead of hardcode message

* unwrap execution exception

* centralise exception handling

* refactor exception catching

* fix a wrong if condition

* make exception test more valuable

* address pr comment