Skip to content

Commit

Permalink
Cherry-pick elastic#17313 to 7.7: Move azure-eventhub input to GA (el…
Browse files Browse the repository at this point in the history
…astic#17320)

* Move azure-eventhub input to GA (elastic#17313)

* Move to GA

* update changelog

* mage fmt update

(cherry picked from commit 1345525)

* changelog fix
  • Loading branch information
narph authored Mar 30, 2020
1 parent ace7f9f commit 0db76d5
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 5 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.next.asciidoc
Original file line number Diff line number Diff line change
Expand Up @@ -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*

Expand Down
2 changes: 0 additions & 2 deletions x-pack/filebeat/docs/inputs/input-azure-eventhub.asciidoc
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,6 @@
<titleabbrev>Azure eventhub</titleabbrev>
++++

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.
Expand Down
3 changes: 0 additions & 3 deletions x-pack/filebeat/input/azureeventhub/input.go
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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)
Expand Down

0 comments on commit 0db76d5

Please sign in to comment.