Skip to content

v2.3.15
Compare
Choose a tag to compare
@sjkwak sjkwak released this 14 Apr 17:45
· 59 commits to master since this release
v2.3.15
ad3f840
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Learn about vigilant mode.

Release notes:

  • Add support for different partitioning strategies to deal with reader/executor skew (#478).
  • Add null check for properties key-value and a test case (#483)
  • Fix an issue of closing a receiver for epoch receiver case (#486)
  • Fix IllegalStateException issue and recreate a receiver if the receiver was closed (#490)
  • Encrypt connection string in eventhub conf (#491)
  • Use receiver timeout for underlying API calls to Event Hubs so that connector can retry on failures (#492)
  • Add receive, send listener for getting performance metrics (#473)
  • Fix a few issues for Scala 2.12 and code clean-up (#498)
  • Add SimpleLogMetricPlugin class (#499)

For PySpark scenario, version 2.3.15 assumes that connection string in the config dictionary is encrypted by the encrypt API in the EventHubsUtils class.

Package link (Scala 2.11) - https://search.maven.org/artifact/com.microsoft.azure/azure-eventhubs-spark_2.11/2.3.15/jar

Package link (Scala 2.12) - https://search.maven.org/artifact/com.microsoft.azure/azure-eventhubs-spark_2.12/2.3.15/jar

Assets 2
Loading