This is an automated email from the ASF dual-hosted git repository.

dajac 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 09793275208 KAFKA-16306: fix GroupCoordinatorService logger (#15433)
09793275208 is described below

commit 097932752087be671f3411d531c50a623dc41b87
Author: Jeff Kim <[email protected]>
AuthorDate: Tue Feb 27 08:45:55 2024 -0500

    KAFKA-16306: fix GroupCoordinatorService logger (#15433)
    
    This patch corrects the logger used for GroupCoordinatorService.
    
    Reviewers: Anton Liauchuk <[email protected]>, David Jacot 
<[email protected]>
---
 .../apache/kafka/coordinator/group/GroupCoordinatorService.java  | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java
 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java
index f635b705e9d..a2363b48222 100644
--- 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java
+++ 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java
@@ -230,9 +230,10 @@ public class GroupCoordinatorService implements 
GroupCoordinator {
 
     /**
      *
-     * @param logContext
-     * @param config
-     * @param runtime
+     * @param logContext                The log context.
+     * @param config                    The group coordinator config.
+     * @param runtime                   The runtime.
+     * @param groupCoordinatorMetrics   The group coordinator metrics.
      */
     GroupCoordinatorService(
         LogContext logContext,
@@ -240,7 +241,7 @@ public class GroupCoordinatorService implements 
GroupCoordinator {
         CoordinatorRuntime<GroupCoordinatorShard, Record> runtime,
         GroupCoordinatorMetrics groupCoordinatorMetrics
     ) {
-        this.log = logContext.logger(CoordinatorLoader.class);
+        this.log = logContext.logger(GroupCoordinatorService.class);
         this.config = config;
         this.runtime = runtime;
         this.groupCoordinatorMetrics = groupCoordinatorMetrics;

Reply via email to