Skip to content

Commit

Permalink
Move azure-eventhub input to GA (elastic#17313)
Browse files Browse the repository at this point in the history
* Move to GA

* update changelog

* mage fmt update
  • Loading branch information
narph committed Mar 30, 2020
1 parent 7a65724 commit 1345525
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 @@ -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] {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 1345525

Please sign in to comment.