English 中文(简体)
为什么数据网不能连接到卡夫卡?
原标题:Why can t Datanode connect to kafka?
I am running Milvus 2.3.11 and using bitnami kafka for my log broker. Due to many critical vulnerabilities in bitnami/kafka:3.1.0-debian-10-r52, I upgraded kafka to 3.7.0-debian-12-r6 After the upgrade datanode started throwing the following errors FAIL|rdkafka#consumer-6| [thrd:GroupCoordinator]: GroupCoordinator: milvus-kafka-0.milvus-kafka-headless.milvus-database.svc.cluster.local:9092: Failed to │ │ resolve milvus-kafka-0.milvus-kafka-headless.milvus-database.svc.cluster.local:9092 : Name or service not known (after 2ms in state CONNECT, 1 identical error(s) suppressed) I believe it is not able to connect to kafka. I ran nslookup milvus-kafka-0.milvus-kafka-headless.milvus-database.svc.cluster.local on a pod in the same namespace and it was able to resolve the host. But I have not idea why my datanode cannot connect to kafka. I reverted back to the previous deployment but I keep getting the same error. I have tried restarting both kafka and datanode pods but I get the same errors. Now, I am not sure if the error started before my kafka upgrade but I noticed it after the upgrade. Thanks in advance for your help.
问题回答
I believe it is most likely a deployment issue, specifically might be with the network configurations on the Kafka side. Make sure your error level is set correctly so the all the info logs will display accordingly.




相关问题
为什么数据网不能连接到卡夫卡?

我经营Milvus 2.3.11 并用比特南米卡夫卡为我的日志经纪人服务。 由于Bitnami/kafka:3.1.0-debian-10-r52中存在许多严重的脆弱性,我将卡夫卡升级为3.7.0-debian-12-r6。......

PyMilvus的客户th-safe & fork-safe?

I m thinking about using Milvus vector storage in my Flask based project and looking at the PyMilvus (Python SDK) documentation. I haven t found any information yet about: Is PyMilvus thread-safe? Is ...

Multivector hybridsearch function is not working

I followed the documentation:https://milvus.io/docs/multi-vector-search.md to perform a multivector hybrid search, but I encountered an error when performing Step 3: Perform a Hybrid Search. res = ...

Why is my vector database retrieving irrelevant results?

I m trying to create a vector database in python using LangChain for retrieval augmentation with a large language model. Currently, I m using NCBI Statpearls (a corpus of medical data) and for testing ...

Return Value Empty When Searching with Milvus

I was attempting to create a Milvus collection using this function below def __generate_collection(self): if self.collection_name not in self.milvusClient.list_collections(): schema = ...

热门标签