Release v0.13.0-rc.1
Pre-release
Pre-release
Breaking Changes
cb
connector configpath
changed topaths
.- Introduce breaking change in
kafka_consumer
configuration, by addingmode
. - Update grok to 0.2, optional patterns are now omitted no longer ""
- Unify to
url
instead ofendpoint
for google and s3 connectors so they're in line with every other connector - Unify to
urls
forelastic
connector - Unify to
path
forbench
,kv
andwal
connector so it's in line with file - Rename
s3_writer
tos3_streamer
New features
- Add
gcl_writer
Google Cloud Platform Cloud Logging connector for writing log entries - Add reverse functions and tests for arrays and strings, add sort test for arrays
- Add a ClickHouse connector
- Add a GCS streamer connector
Fixes
- Fix bug in the runtime, swallowing some event acknowledgements and fails for batched events from multiple streams
- Fix custom metrics for
kafka_consumer
,kafka_producer
not being reported in the requested interval - Fix
metrics
connector not emitting all metrics it did receive. - Fix invalid scope handling for
flow
definition default arguments - Fix
elastic
sink not acking events handled successfully if no source is connected. - Fix
kafka_consumer
possibly committing earlier offsets, thus replaying events that have already been handled. - Fix off-by-one error in
kafka_consumer
committing offsets, thus replaying the last committed event. - Allow
kafka_consumer
connector to reconnect upon more error conditions and avoid stalls. - Include flow alias in pipeline and connector aliases reported via metrics events and logging in order to deduplicate entries