- Added required kusto.query.url parameter so that we can now specify a Kusto Query URL that isn't simply the default of the Kusto Ingestion URL prepended with "ingest-".
- Renamed the kusto.url parameter to kusto.ingestion.url for clarity and consistency.
** Bug fix **
- Trying to create a new directory failed probably because it was already created due to a race condition.
- Resetting the timer was not behind lock, which could result in a race condition of it being destroyed by other code.
Please note that this is a pre-release, as it should've been a version change at the major instead of patch level, since it includes a breaking change because of the new required parameter kusto.query.url and the kusto.url parameter now named kusto.ingestion.url.
** Bug fix **
Fix Multijson usage
Cast of count of records to long failed if an integer was found
** Bug fix **
Cast of count of records to long instead of int, to accommodate larger databases.
** Bug fix **
Correct committed offset value to be (+ 1) so as not to ingest last record twice
New Features
- Support for dlq
- Support json and avro schema registry
- Support json and avro converters
Bug fix
In certain kafka pipelines - the connector files were deleted before ingestion.
** Bug Fix **
Client was closed when kafka task was called close() certain partitions. Now closing only on stop. Issue resulted in no refresh of the ingestion resources and caused failure on ingest when trying to add message to the azure queue.