Chia-Ping Tsai created KAFKA-19033:
--------------------------------------
Summary: FindCoordinator API always return
COORDINATOR_NOT_AVAILABLE for CoordinatorType.SHARE
Key: KAFKA-19033
URL: https://issues.apache.org/jira/browse/KAFKA-19033
Project: Kafka
Issue Type: Bug
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaApis.scala#L1183
*before*
{code:java}
(shareCoordinator.foreach(coordinator =>
coordinator.partitionFor(SharePartitionKey.getInstance(key))),
SHARE_GROUP_STATE_TOPIC_NAME)
{code}
*after*
{code:java}
(shareCoordinator.get.partitionFor(SharePartitionKey.getInstance(key)),
SHARE_GROUP_STATE_TOPIC_NAME)
{code}
noted that the existence of shareCoordinator is already checked before.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
