Shekharrajak commented on code in PR #22357:
URL: https://github.com/apache/kafka/pull/22357#discussion_r3423493147
##########
core/src/main/scala/kafka/server/KafkaApis.scala:
##########
@@ -3777,53 +3777,45 @@ class KafkaApis(val requestChannel: RequestChannel,
return CompletableFuture.completedFuture[Unit](())
}
- groupCoordinator.validateShareGroupMember(request.context, groupId,
memberId, data.memberEpoch)
Review Comment:
TxnShareAcknowledgeRequest is routed to the source partition leader, not
the group coordinator. so `groupCoordinator.validateShareGroupMember` failed
during IT .
example :
```
Broker 0 = source topic-partition leader
Broker 1 = share group coordinator
Broker 2 = transaction coordinator
```
Broker 0 is not the coordinator for that group, so it returned
NOT_COORDINATOR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
