diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc index 873e853424f..75712ec2898 100644 --- a/CHANGELOG.next.asciidoc +++ b/CHANGELOG.next.asciidoc @@ -114,6 +114,7 @@ https://github.com/elastic/beats/compare/v8.8.1\...main[Check the HEAD diff] - Filter out duplicate paths resolved from matching globs. {issue}36253[36253] {pull}36256[36256] - Fix handling of TCP/UDP address resolution during metric initialization. {issue}35064[35064] {pull}36287[36287] - Fix handling of Juniper SRX structured data when there is no leading junos element. {issue}36270[36270] {pull}36308[36308] +- Remove erroneous error log in GCPPubSub input. {pull}36296[36296] *Heartbeat* diff --git a/x-pack/filebeat/input/gcppubsub/input.go b/x-pack/filebeat/input/gcppubsub/input.go index 890e8b1ee10..6547333a5e0 100644 --- a/x-pack/filebeat/input/gcppubsub/input.go +++ b/x-pack/filebeat/input/gcppubsub/input.go @@ -147,7 +147,6 @@ func NewInput(cfg *conf.C, connector channel.Connector, inputContext input.Conte in.metrics.ackedMessageCount.Inc() in.metrics.bytesProcessedTotal.Add(uint64(len(msg.Data))) in.metrics.processingTime.Update(time.Since(msg.PublishTime).Nanoseconds()) - in.log.Error("ACKing pub/sub event") } else { in.metrics.failedAckedMessageCount.Inc() in.log.Error("Failed ACKing pub/sub event")