From eb3c55cd0346777fd39d4100c5c552986029b504 Mon Sep 17 00:00:00 2001 From: xige-16 Date: Tue, 29 Sep 2020 19:10:41 +0800 Subject: [PATCH] Fix write node consume busy Signed-off-by: xige-16 --- .gitignore | 1 + writer/message_client/message_client.go | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/.gitignore b/.gitignore index e24b5efcb..f893fa395 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 f38c5c60d..92c10223b 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 { -- GitLab