Revert "AKCORE-627 : Add Share Group Commands for Confluent CLI (#3185)" (#3228)

Author: cqin-confluent

go.mod

@@ -35,7 +35,7 @@ require (
 	github.com/confluentinc/ccloud-sdk-go-v2/iam-ip-filtering v0.5.0
 	github.com/confluentinc/ccloud-sdk-go-v2/identity-provider v0.3.0
 	github.com/confluentinc/ccloud-sdk-go-v2/kafka-quotas v0.4.0
-	github.com/confluentinc/ccloud-sdk-go-v2/kafkarest v0.0.0-20250909043602-f80bee0eb280
+	github.com/confluentinc/ccloud-sdk-go-v2/kafkarest v0.24.0
 	github.com/confluentinc/ccloud-sdk-go-v2/ksql v0.2.0
 	github.com/confluentinc/ccloud-sdk-go-v2/mds v0.4.0
 	github.com/confluentinc/ccloud-sdk-go-v2/metrics v0.2.0

go.sum

@@ -228,8 +228,8 @@ github.com/confluentinc/ccloud-sdk-go-v2/identity-provider v0.3.0 h1:COUuWIW9GLz
 github.com/confluentinc/ccloud-sdk-go-v2/identity-provider v0.3.0/go.mod h1:VHpsi0yWBEhN6Hp2oOyGkRaNJjtnaVfYjpbtB8pnNnk=
 github.com/confluentinc/ccloud-sdk-go-v2/kafka-quotas v0.4.0 h1:T9e7lNj/VjxE89+tcpX2RS2NE4rWNWbJjxcO2yehEqM=
 github.com/confluentinc/ccloud-sdk-go-v2/kafka-quotas v0.4.0/go.mod h1:7gqwWFIyj2MAGpL/kf6SGXm/pi2Z6qpMJIjKlgEEhhg=
-github.com/confluentinc/ccloud-sdk-go-v2/kafkarest v0.0.0-20250909043602-f80bee0eb280 h1:GFVI3pGckhpP66Xb05usB8txzubnnoigZHp292ax5Rg=
-github.com/confluentinc/ccloud-sdk-go-v2/kafkarest v0.0.0-20250909043602-f80bee0eb280/go.mod h1:b8v8EIBtpQDx0zAxCpGxhuSWBRAwh/+PRFNtaBR5P7c=
+github.com/confluentinc/ccloud-sdk-go-v2/kafkarest v0.24.0 h1:PLmZLAMnY+zgxw687jemgMlqMPmu6OgJssxGlvsjp8M=
+github.com/confluentinc/ccloud-sdk-go-v2/kafkarest v0.24.0/go.mod h1:Sb2O1jlHfLgMrZiqLAPqws0WjAVd4HgocZh3D7EZN5k=
 github.com/confluentinc/ccloud-sdk-go-v2/ksql v0.2.0 h1:g6OHa1iW3HO3N/YiTAL9Q6Y7rdjMBAjOPYK37akTt0M=
 github.com/confluentinc/ccloud-sdk-go-v2/ksql v0.2.0/go.mod h1:0LAvd4VqlaRwKU4yvDEkVCtV43yNezt56+hBe9Lmg7Q=
 github.com/confluentinc/ccloud-sdk-go-v2/mds v0.4.0 h1:jIXXhGi+Xn+XYFCErnMvd035QijbYXla1Bo8W7V7lFM=

internal/kafka/command.go

@@ -24,7 +24,6 @@ func New(cfg *config.Config, prerunner pcmd.PreRunner) *cobra.Command {
 	cmd.AddCommand(newQuotaCommand(prerunner))
 	cmd.AddCommand(newRegionCommand(prerunner))
 	cmd.AddCommand(newReplicaCommand(prerunner))
-	cmd.AddCommand(newShareGroupCommand(prerunner))
 	cmd.AddCommand(newTopicCommand(cfg, prerunner))
 
 	return cmd

internal/kafka/command_share_group.go

@@ -307,30 +307,6 @@ func (c *KafkaRestClient) GetKafkaConsumerLag(consumerGroupId, topicName string,
 	return res, kafkarest.NewError(c.GetUrl(), err, httpResp)
 }
 
-func (c *KafkaRestClient) ListKafkaShareGroups() ([]kafkarestv3.ShareGroupData, error) {
-	res, httpResp, err := c.ShareGroupV3Api.ListKafkaShareGroups(c.kafkaRestApiContext(), c.ClusterId).Execute()
-	if err != nil {
-		return nil, kafkarest.NewError(c.GetUrl(), err, httpResp)
-	}
-	return res.GetData(), nil
-}
-
-func (c *KafkaRestClient) GetKafkaShareGroup(shareGroupId string) (kafkarestv3.ShareGroupData, error) {
-	res, httpResp, err := c.ShareGroupV3Api.GetKafkaShareGroup(c.kafkaRestApiContext(), c.ClusterId, shareGroupId).Execute()
-	if err != nil {
-		return kafkarestv3.ShareGroupData{}, kafkarest.NewError(c.GetUrl(), err, httpResp)
-	}
-	return res, nil
-}
-
-func (c *KafkaRestClient) ListKafkaShareGroupConsumers(shareGroupId string) ([]kafkarestv3.ShareGroupConsumerData, error) {
-	res, httpResp, err := c.ShareGroupV3Api.ListKafkaShareGroupConsumers(c.kafkaRestApiContext(), c.ClusterId, shareGroupId).Execute()
-	if err != nil {
-		return nil, kafkarest.NewError(c.GetUrl(), err, httpResp)
-	}
-	return res.GetData(), nil
-}
-
 func (c *KafkaRestClient) GetKafkaPartition(topicName string, partitionId int32) (kafkarestv3.PartitionData, error) {
 	res, httpResp, err := c.PartitionV3Api.GetKafkaPartition(c.kafkaRestApiContext(), c.ClusterId, topicName, partitionId).Execute()
 	return res, kafkarest.NewError(c.GetUrl(), err, httpResp)

internal/kafka/command_share_group_consumer.go

@@ -592,24 +592,6 @@ func AutocompleteConsumerGroups(cmd *cobra.Command, c *AuthenticatedCLICommand)
 	return suggestions
 }
 
-func AutocompleteShareGroups(cmd *cobra.Command, c *AuthenticatedCLICommand) []string {
-	kafkaREST, err := c.GetKafkaREST(cmd)
-	if err != nil {
-		return nil
-	}
-
-	shareGroups, err := kafkaREST.CloudClient.ListKafkaShareGroups()
-	if err != nil {
-		return nil
-	}
-
-	suggestions := make([]string, len(shareGroups))
-	for i, shareGroup := range shareGroups {
-		suggestions[i] = shareGroup.GetShareGroupId()
-	}
-	return suggestions
-}
-
 func AddNetworkFlag(cmd *cobra.Command, c *AuthenticatedCLICommand) {
 	cmd.Flags().String("network", "", "Network ID.")
 	RegisterFlagCompletionFunc(cmd, "network", func(cmd *cobra.Command, args []string) []string {