[jira] [Created] (KAFKA-18099) The lkc prefix should be removed from the topic name when generating sync response for classic members in consumer group

[Dongnuo Lyu (Jira)]

Dongnuo Lyu created KAFKA-18099:
-----------------------------------

             Summary: The lkc prefix should be removed from the topic name when 
generating sync response for classic members in consumer group
                 Key: KAFKA-18099
                 URL: https://issues.apache.org/jira/browse/KAFKA-18099
             Project: Kafka
          Issue Type: Sub-task
            Reporter: Dongnuo Lyu
            Assignee: Dongnuo Lyu


We are seeing classic member in consumer group keeping rejoining because of the 
error 
{code:java}
[2024-11-26 20:52:47,213] INFO [Consumer clientId=consumer-c332-1, 
groupId=c332] Assigned partition lkc-devcnmj1wd_nov-26-322-3 for non-subscribed 
topic; subscription is [nov-26-322] 
(org.apache.kafka.clients.consumer.internals.SubscriptionState) 

[2024-11-26 20:52:47,213] INFO [Consumer clientId=consumer-c332-1, 
groupId=c332] Request joining group due to: received assignment 
[lkc-devcnmj1wd_nov-26-322-3, lkc-devcnmj1wd_nov-26-322-4, 
lkc-devcnmj1wd_nov-26-322-5] does not match the current subscription 
Subscribe(nov-26-322); it is likely that the subscription has changed since we 
joined the group, will re-join with current subscription 
(org.apache.kafka.clients.consumer.internals.ConsumerCoordinator){code}
The issue is that we look up the topic id from the metadata image where the 
topic has an lkc prefix when generating the sync response. We should remove the 
prefix.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)