You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2024/06/29 16:31:59 UTC
(kafka) branch trunk updated: MINOR: Align coordinator loader metrics data type (#16481)
This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new bb3c35b2659 MINOR: Align coordinator loader metrics data type (#16481)
bb3c35b2659 is described below
commit bb3c35b265920dd0cb2a0884115c8a525bee094f
Author: Xiduo You <ul...@gmail.com>
AuthorDate: Sun Jun 30 00:31:53 2024 +0800
MINOR: Align coordinator loader metrics data type (#16481)
Reviewers: David Jacot <da...@gmail.com>, Chia-Ping Tsai <ch...@gmail.com>
---
.../main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala b/core/src/main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala
index 7dcad67a4dd..3e45e4c16e6 100644
--- a/core/src/main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala
+++ b/core/src/main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala
@@ -99,8 +99,8 @@ class CoordinatorLoaderImpl[T](
var readAtLeastOneRecord = true
var previousHighWatermark = -1L
- var numRecords = 0
- var numBytes = 0
+ var numRecords = 0L
+ var numBytes = 0L
while (currentOffset < logEndOffset && readAtLeastOneRecord && isRunning.get) {
val fetchDataInfo = log.read(
startOffset = currentOffset,