diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-10 13:10:45 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-10 13:10:45 -0700 |
| commit | 8cc5298a08db7c7d21d6bb657bab2277e143500d (patch) | |
| tree | 1aa746c8e404c771843417171c71f3ccc1777b89 | |
| parent | d3032d1e805ab363242c833d9a61db59b3941f21 (diff) | |
| download | seaweedfs-8cc5298a08db7c7d21d6bb657bab2277e143500d.tar.xz seaweedfs-8cc5298a08db7c7d21d6bb657bab2277e143500d.zip | |
clean up unused variables
| -rw-r--r-- | weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go | 1 | ||||
| -rw-r--r-- | weed/mq/client/cmd/weed_sub_record/subscriber_record.go | 1 | ||||
| -rw-r--r-- | weed/mq/client/sub_client/subscriber.go | 3 |
3 files changed, 0 insertions, 5 deletions
diff --git a/weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go b/weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go index adcdda04c..e920e73c7 100644 --- a/weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go +++ b/weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go @@ -25,7 +25,6 @@ func main() { flag.Parse() subscriberConfig := &sub_client.SubscriberConfiguration{ - ClientId: fmt.Sprintf("client-%d", *clientId), ConsumerGroup: "test", ConsumerGroupInstanceId: fmt.Sprintf("client-%d", *clientId), GrpcDialOption: grpc.WithTransportCredentials(insecure.NewCredentials()), diff --git a/weed/mq/client/cmd/weed_sub_record/subscriber_record.go b/weed/mq/client/cmd/weed_sub_record/subscriber_record.go index 53eb4f15b..988e40419 100644 --- a/weed/mq/client/cmd/weed_sub_record/subscriber_record.go +++ b/weed/mq/client/cmd/weed_sub_record/subscriber_record.go @@ -51,7 +51,6 @@ func main() { flag.Parse() subscriberConfig := &sub_client.SubscriberConfiguration{ - ClientId: fmt.Sprintf("client-%d", *clientId), ConsumerGroup: "test", ConsumerGroupInstanceId: fmt.Sprintf("client-%d", *clientId), GrpcDialOption: grpc.WithTransportCredentials(insecure.NewCredentials()), diff --git a/weed/mq/client/sub_client/subscriber.go b/weed/mq/client/sub_client/subscriber.go index 982c3f13b..3f343ed1d 100644 --- a/weed/mq/client/sub_client/subscriber.go +++ b/weed/mq/client/sub_client/subscriber.go @@ -11,9 +11,6 @@ type SubscriberConfiguration struct { ClientId string ConsumerGroup string ConsumerGroupInstanceId string - GroupMinimumPeers int32 - GroupMaximumPeers int32 - BootstrapServers []string GrpcDialOption grpc.DialOption } |