You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
json and logfmt loggers - fields time and msg replaced with @timestamp and message
kafka plugins - added connections init check to prevent pipeline startup if brokers unavailable via network
new param for all filters - reverse; it's like a NOT condition
plugin-to-plugin channels metrics implemented
dummy probe at /probe endpoint added; probe responds 200 OK only after all pipelines started at service startup (of course, if pipelines has run = true parameter)
daemon config now supports ENVs expantion
new engine param - fail_fast; when true, service exits with error when at least one pipeline start failed
internal pipelines manager should be concurrent-safe now (as a result, HTTP api also concurrent-safe)
Docker container - non-root run from 9600:9600 user
pipeline CLI commands now has --request-timeout option
Bugfixes
SQLX oracle bindings now works as expected
Kafka input now correctly handle consumers rebalancing and waits for all events delivery, if they was created from one message