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 2026/09/09 03:24:15 UTC

(kafka) branch trunk updated: KAFKA-21045 Register NoOpAssignmentRefiner in native image reflect-config (#23399)

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 e88e9d7bdee KAFKA-21045 Register NoOpAssignmentRefiner in native image reflect-config (#23399)
e88e9d7bdee is described below

commit e88e9d7bdeeb38c928b3a07f294bf43b44240e90
Author: Murali Basani <mu...@aiven.io>
AuthorDate: Wed Sep 9 05:24:04 2026 +0200

    KAFKA-21045 Register NoOpAssignmentRefiner in native image reflect-config (#23399)
    
    Ref : https://issues.apache.org/jira/browse/KAFKA-21045
    
    Problem : Consumer groups fail to load on the native image with a
    NoSuchMethodException for NoOpAssignmentRefiner.<init>() when a
    __consumer_offsets partition loads — independent of the security
    protocol.
    
    ```
    kafka19583-broker  | [2026-09-07 14:07:23,272] ERROR [GroupCoordinator
    id=1] Execution of Load(tp=__consumer_offsets-35, epoch=0) failed due to
    Could not find a public no-argument constructor for
    org.apache.kafka.coordinator.group.streams.NoOpAssignmentRefiner.
    (org.apache.kafka.coordinator.common.runtime.CoordinatorRuntime)
    kafka19583-broker  | org.apache.kafka.common.KafkaException: Could not
    find a public no-argument constructor for
    org.apache.kafka.coordinator.group.streams.NoOpAssignmentRefiner
    kafka19583-broker  |    at
    org.apache.kafka.common.utils.Utils.newInstance(Utils.java:414)
    kafka19583-broker  |    at
    org.apache.kafka.common.config.AbstractConfig.getConfiguredInstance(AbstractConfig.java:411)
    ```
    
    Reviewers: Matthias J. Sax <ma...@confluent.io>, Chia-Ping Tsai
     <ch...@gmail.com>
---
 docker/native/native-image-configs/reflect-config.json | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/docker/native/native-image-configs/reflect-config.json b/docker/native/native-image-configs/reflect-config.json
index b36559f848b..25f66043740 100644
--- a/docker/native/native-image-configs/reflect-config.json
+++ b/docker/native/native-image-configs/reflect-config.json
@@ -1080,6 +1080,10 @@
   "name":"org.apache.kafka.coordinator.group.assignor.UniformAssignor",
   "methods":[{"name":"<init>","parameterTypes":[] }]
 },
+{
+  "name":"org.apache.kafka.coordinator.group.streams.NoOpAssignmentRefiner",
+  "methods":[{"name":"<init>","parameterTypes":[] }]
+},
 {
   "name":"org.apache.kafka.metadata.authorizer.StandardAuthorizer",
   "methods":[{"name":"<init>","parameterTypes":[] }]