From 71a92fae73faa8f35cc710dd205e2967b74e473d Mon Sep 17 00:00:00 2001 From: Mariana Dima Date: Mon, 30 Mar 2020 16:01:45 +0200 Subject: [PATCH] Cherry-pick #17313 to 7.7: Move azure-eventhub input to GA (#17320) * Move azure-eventhub input to GA (#17313) * Move to GA * update changelog * mage fmt update (cherry picked from commit 4912c8c0fa3993a3eb3921a47e9085d057e13eec) * changelog fix --- CHANGELOG.next.asciidoc | 1 + x-pack/filebeat/docs/inputs/input-azure-eventhub.asciidoc | 2 -- x-pack/filebeat/input/azureeventhub/input.go | 3 --- 3 files changed, 1 insertion(+), 5 deletions(-) diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc index 1965149d3533..149342a03d5f 100644 --- a/CHANGELOG.next.asciidoc +++ b/CHANGELOG.next.asciidoc @@ -284,6 +284,7 @@ https://github.com/elastic/beats/compare/v7.0.0-alpha2...master[Check the HEAD d - Added new module `o365` for ingesting Office 365 management activity API events. {issue}16196[16196] {pull}16386[16386] - Add Filebeat Okta module. {pull}16362[16362] - Improve AWS cloudtrail field mappings {issue}16086[16086] {issue}16110[16110] {pull}17155[17155] +- Move azure-eventhub input to GA. {issue}15671[15671] {pull}17313[17313] *Heartbeat* diff --git a/x-pack/filebeat/docs/inputs/input-azure-eventhub.asciidoc b/x-pack/filebeat/docs/inputs/input-azure-eventhub.asciidoc index bd2014bcd59f..15b628169cea 100644 --- a/x-pack/filebeat/docs/inputs/input-azure-eventhub.asciidoc +++ b/x-pack/filebeat/docs/inputs/input-azure-eventhub.asciidoc @@ -9,8 +9,6 @@ Azure eventhub ++++ -beta[] - Users can make use of the `azure-eventhub` input in order to read messages from an azure eventhub. The azure-eventhub input implementation is based on the the event processor host (EPH is intended to be run across multiple processes and machines while load balancing message consumers more on this here https://github.com/Azure/azure-event-hubs-go#event-processor-host, https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-event-processor-host). State such as leases on partitions and checkpoints in the event stream are shared between receivers using an Azure Storage container. For this reason, as a prerequisite to using this input, users will have to create or use an existing storage account. diff --git a/x-pack/filebeat/input/azureeventhub/input.go b/x-pack/filebeat/input/azureeventhub/input.go index 1435801893de..2cf6494f8d76 100644 --- a/x-pack/filebeat/input/azureeventhub/input.go +++ b/x-pack/filebeat/input/azureeventhub/input.go @@ -11,8 +11,6 @@ import ( "sync" "time" - "github.com/elastic/beats/v7/libbeat/common/cfgwarn" - "github.com/pkg/errors" "github.com/elastic/beats/v7/filebeat/channel" @@ -62,7 +60,6 @@ func NewInput( connector channel.Connector, inputContext input.Context, ) (input.Input, error) { - cfgwarn.Beta("The %s input is beta", inputName) var config azureInputConfig if err := cfg.Unpack(&config); err != nil { return nil, errors.Wrapf(err, "reading %s input config", inputName)