Skip to content

[Feature][integration][Java] Java Implementation of Vector Store with Milvus Support #661

Closed

Description

@yanbinyang

Search before asking

  • I searched in the issues and found nothing similar.

Description

Following the design proposal in #143 and infrastructure introduced in #321, we want to add a Milvus-based vector store implementation to enhance RAG capabilities with Milvus in Flink Agents. This issue focuses on implementing the Java Milvus vector store integration.

The implementation should include:

  • Add MilvusVectorStore under integrations/vector-stores/milvus
  • Reuse the existing BaseVectorStore, Document, VectorStoreQuery, and VectorStoreQueryResult APIs
  • Support Milvus connection configuration, such as uri, token, username, password, and database
  • Support collection/search configuration, such as collection_name, vector_field, text_field, primary_key_field, output_fields, and search params
  • Convert Milvus query results into the common Document type
  • Add unit tests and/or integration tests for query argument parsing and result conversion

Are you willing to submit a PR?

  • I'm willing to submit a PR!

Activity

  1. added
    feature[Issue Type] New features or improvements to existing features.
    priority/majorDefault priority of the PR or issue.
    on May 12, 2026
  2. wenjin272 commented on May 12, 2026

    @wenjin272
    Contributor

    Thanks @yanbinyang. Assigned.

  3. added
    fixVersion/0.3.0The feature or bug should be implemented/fixed in the 0.3.0 version.
    on Jun 9, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

Labels

feature[Issue Type] New features or improvements to existing features.fixVersion/0.3.0The feature or bug should be implemented/fixed in the 0.3.0 version.priority/majorDefault priority of the PR or issue.

Type

No type

Projects

No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions