|
@ -25,7 +25,6 @@ func main() { |
|
|
flag.Parse() |
|
|
flag.Parse() |
|
|
|
|
|
|
|
|
subscriberConfig := &sub_client.SubscriberConfiguration{ |
|
|
subscriberConfig := &sub_client.SubscriberConfiguration{ |
|
|
ClientId: fmt.Sprintf("client-%d", *clientId), |
|
|
|
|
|
ConsumerGroup: "test", |
|
|
ConsumerGroup: "test", |
|
|
ConsumerGroupInstanceId: fmt.Sprintf("client-%d", *clientId), |
|
|
ConsumerGroupInstanceId: fmt.Sprintf("client-%d", *clientId), |
|
|
GrpcDialOption: grpc.WithTransportCredentials(insecure.NewCredentials()), |
|
|
GrpcDialOption: grpc.WithTransportCredentials(insecure.NewCredentials()), |
|
|