diff --git a/.gitignore b/.gitignore index e24b5efcb76cd97977f43d05c9de3e312ed90df7..f893fa3952dffcfb52a06912d3bb4dc67fa40faf 100644 --- a/.gitignore +++ b/.gitignore @@ -27,6 +27,7 @@ proxy/milvus proxy/cmake_build proxy/cmake-build-debug proxy/cmake-build-release +proxy/cmake_build_release proxy/thirdparty/grpc-src proxy/thirdparty/grpc-build proxy/milvus/* diff --git a/writer/message_client/message_client.go b/writer/message_client/message_client.go index f38c5c60d586da6b34408867f2d228317a84c3be..92c10223b2d5dab459c4375b013ab8bb16edb17d 100644 --- a/writer/message_client/message_client.go +++ b/writer/message_client/message_client.go @@ -87,7 +87,7 @@ func (mc *MessageClient) creatProducer(topicName string) pulsar.Producer { func (mc *MessageClient) createConsumer(topicName string) pulsar.Consumer { consumer, err := mc.client.Subscribe(pulsar.ConsumerOptions{ Topic: topicName, - SubscriptionName: "writer", + SubscriptionName: "writer" + strconv.Itoa(mc.MessageClientID), }) if err != nil {