[filebeat][httpjson] Fix counter for number of published events (#31993)

* Fix counter used for logging number of published events * Update CHANGELOG
elastic · Jun 1, 2023 · e41073f · e41073f
1 parent b6bb4bc
commit e41073f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc
@@ -53,6 +53,7 @@ https://github.com/elastic/beats/compare/v8.2.0\...main[Check the HEAD diff]
 - Fix wrong state ID in states registry for awss3 s3 direct input. {pull}32164[32164]
 - cisco/asa: fix handling of user names when there are Security Group Tags present. {issue}32009[32009] {pull}32196[32196]
 - Fix race conditions when reloading input V2 and filestream input {pull}32309[32309]
+- Fix counter for number of events published in `httpjson` input. {pull}31993[31993]
 
 *Heartbeat*
 

diff --git a/x-pack/filebeat/input/httpjson/request.go b/x-pack/filebeat/input/httpjson/request.go
@@ -341,7 +341,7 @@ func (r *requester) doRequest(stdCtx context.Context, trCtx *transformContext, p
 				}
 				resps = intermediateResps
 			}
-			n = r.processAndPublishEvents(stdCtx, trCtx, publisher, resps, i < len(r.requestFactories), i)
+			n += r.processAndPublishEvents(stdCtx, trCtx, publisher, resps, i < len(r.requestFactories), i)
 		}
 	}
-Original file line number
+Diff line change
@@ Expand Up @@
     				}
     				resps = intermediateResps
     			}
-    			n = r.processAndPublishEvents(stdCtx, trCtx, publisher, resps, i < len(r.requestFactories), i)
+    			n += r.processAndPublishEvents(stdCtx, trCtx, publisher, resps, i < len(r.requestFactories), i)
     		}
     	}
@@ Expand Down @@