From 6634b429812310b38c0efc7f05a9c8fa3911aa68 Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Tue, 21 May 2024 08:26:55 -0700
Subject: [PATCH] fix compilation

---
 weed/mq/client/sub_client/connect_to_sub_coordinator.go | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git a/weed/mq/client/sub_client/connect_to_sub_coordinator.go b/weed/mq/client/sub_client/connect_to_sub_coordinator.go
index a73161fea..9dd639fce 100644
--- a/weed/mq/client/sub_client/connect_to_sub_coordinator.go
+++ b/weed/mq/client/sub_client/connect_to_sub_coordinator.go
@@ -63,13 +63,8 @@ func (sub *TopicSubscriber) doKeepConnectedToSubCoordinator() {
 						glog.V(0).Infof("subscriber %s receive: %v", sub.ContentConfig.Topic, err)
 						return err
 					}
-					assignment := resp.GetAssignment()
-					if assignment != nil {
-						glog.V(0).Infof("subscriber %s receive assignment: %v", sub.ContentConfig.Topic, assignment)
-						for _, assignedPartition := range assignment.PartitionAssignments {
-							sub.brokerPartitionAssignmentChan <- assignedPartition
-						}
-					}
+					sub.brokerPartitionAssignmentChan <- resp
+					glog.V(0).Infof("Received assignment: %+v", resp)
 				}
 
 				return nil