diff --git a/CHANGELOG.md b/CHANGELOG.md index 633b3a41dd..b7c4a8c093 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -2,10 +2,6 @@ ## Latest -### Breaking Changes - -* elastic sink config value `endpoints` renamed to `nodes` [#715](https://github.com/tremor-rs/tremor-runtime/pull/715) - ### New features * Default to thin-lto for all builds (prior this was only done in docker) diff --git a/src/sink/elastic.rs b/src/sink/elastic.rs index 2efe11ba4f..ef32c60bcb 100644 --- a/src/sink/elastic.rs +++ b/src/sink/elastic.rs @@ -51,7 +51,7 @@ use tremor_script::Object; #[derive(Debug, Deserialize)] pub struct Config { /// list of endpoint urls - pub nodes: Vec, + pub endpoints: Vec, /// maximum number of paralel in flight batches (default: 4) #[serde(default = "concurrency")] pub concurrency: usize, @@ -78,7 +78,7 @@ impl offramp::Impl for Elastic { if let Some(config) = config { let config: Config = Config::new(config)?; let client = SyncClientBuilder::new() - .static_nodes(config.nodes.into_iter()) + .static_nodes(config.endpoints.into_iter()) .build()?; let queue = AsyncSink::new(config.concurrency);