Skip to content

feat(connector): Add Opensearch source connector #3503

@ryerraguntla

Description

@ryerraguntla

Description

Add a Opensearch source connector that polls documents from a Opensearch index and produces JSON messages into Iggy.

Users should be able to ingest Opensearch documents into Iggy streams with stable cursor-based polling and persisted connector state.

Affected area / component

Connectors

Proposed solution

Scope
Add the source connector crate and sample runtime config.
Document source configuration, retry behavior, and primary-key cursor requirements.
Add Docker-backed integration coverage for producing indexed documents.

Alternatives considered

No response

Contribution

  • I'm willing to submit a pull request to implement this feature

Good first issue

  • I think this could be a good first issue for a new contributor

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions