[
https://issues.apache.org/jira/browse/KAFKA-18099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-18099.
---------------------------------
Resolution: Invalid
> 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
> Priority: Major
>
> 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)
