From 46f29dd74c1738e7e9788da029a5ba84d06815db Mon Sep 17 00:00:00 2001 From: Mariana Date: Mon, 30 Mar 2020 12:08:19 +0200 Subject: [PATCH 1/3] Move to GA --- CHANGELOG.next.asciidoc | 1 + x-pack/filebeat/docs/inputs/input-azure-eventhub.asciidoc | 2 -- x-pack/filebeat/input/azureeventhub/input.go | 5 +---- 3 files changed, 2 insertions(+), 6 deletions(-) diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc index c5049f9f8cd..2f7387b45af 100644 --- a/CHANGELOG.next.asciidoc +++ b/CHANGELOG.next.asciidoc @@ -212,6 +212,7 @@ https://github.com/elastic/beats/compare/v7.0.0-alpha2...master[Check the HEAD d - Add source field in k8s events {pull}17209[17209] - Improve AWS cloudtrail field mappings {issue}16086[16086] {issue}16110[16110] {pull}17155[17155] - Added documentation for running Filebeat in Cloud Foundry. {pull}17275[17275] +- Move azure-eventhub input to GA. {issue}15671[15671] *Heartbeat* diff --git a/x-pack/filebeat/docs/inputs/input-azure-eventhub.asciidoc b/x-pack/filebeat/docs/inputs/input-azure-eventhub.asciidoc index bd2014bcd59..15b628169ce 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 1435801893d..9d0503e1187 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" @@ -21,7 +19,7 @@ import ( "github.com/elastic/beats/v7/libbeat/common" "github.com/elastic/beats/v7/libbeat/logp" - eventhub "github.com/Azure/azure-event-hubs-go/v3" + "github.com/Azure/azure-event-hubs-go/v3" "github.com/Azure/azure-event-hubs-go/v3/eph" ) @@ -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) From 9577e0e709707b01aab8b5e32302db56609840dd Mon Sep 17 00:00:00 2001 From: Mariana Date: Mon, 30 Mar 2020 12:14:26 +0200 Subject: [PATCH 2/3] update changelog --- CHANGELOG.next.asciidoc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc index 2f7387b45af..728432a10c6 100644 --- a/CHANGELOG.next.asciidoc +++ b/CHANGELOG.next.asciidoc @@ -212,7 +212,7 @@ https://github.com/elastic/beats/compare/v7.0.0-alpha2...master[Check the HEAD d - Add source field in k8s events {pull}17209[17209] - Improve AWS cloudtrail field mappings {issue}16086[16086] {issue}16110[16110] {pull}17155[17155] - Added documentation for running Filebeat in Cloud Foundry. {pull}17275[17275] -- Move azure-eventhub input to GA. {issue}15671[15671] +- Move azure-eventhub input to GA. {issue}15671[15671] {pull}17313[17313] *Heartbeat* From 0dedf6cd671e77bb8d3b613914872062bf4ff458 Mon Sep 17 00:00:00 2001 From: Mariana Date: Mon, 30 Mar 2020 12:55:31 +0200 Subject: [PATCH 3/3] mage fmt update --- x-pack/filebeat/input/azureeventhub/input.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/x-pack/filebeat/input/azureeventhub/input.go b/x-pack/filebeat/input/azureeventhub/input.go index 9d0503e1187..2cf6494f8d7 100644 --- a/x-pack/filebeat/input/azureeventhub/input.go +++ b/x-pack/filebeat/input/azureeventhub/input.go @@ -19,7 +19,7 @@ import ( "github.com/elastic/beats/v7/libbeat/common" "github.com/elastic/beats/v7/libbeat/logp" - "github.com/Azure/azure-event-hubs-go/v3" + eventhub "github.com/Azure/azure-event-hubs-go/v3" "github.com/Azure/azure-event-hubs-go/v3/eph" )