Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Pull-based Ingestion] Add error handling strategy to pull-based ingestion #17427

Merged
merged 2 commits into from
Mar 4, 2025

Make error strategy config type-safe

a431b14
Select commit
Loading
Failed to load commit list.
Merged

[Pull-based Ingestion] Add error handling strategy to pull-based ingestion #17427

Make error strategy config type-safe
a431b14
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Mar 4, 2025 in 1s

88.52% of diff hit (target 72.46%)

View this Pull Request on Codecov

88.52% of diff hit (target 72.46%)

Annotations

Check warning on line 137 in plugins/ingestion-kafka/src/main/java/org/opensearch/plugin/kafka/KafkaPartitionConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kafka/src/main/java/org/opensearch/plugin/kafka/KafkaPartitionConsumer.java#L137

Added line #L137 was not covered by tests

Check warning on line 35 in server/src/main/java/org/opensearch/indices/pollingingest/IngestionErrorStrategy.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

server/src/main/java/org/opensearch/indices/pollingingest/IngestionErrorStrategy.java#L35

Added line #L35 was not covered by tests

Check warning on line 54 in server/src/main/java/org/opensearch/indices/pollingingest/IngestionErrorStrategy.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

server/src/main/java/org/opensearch/indices/pollingingest/IngestionErrorStrategy.java#L53-L54

Added lines #L53 - L54 were not covered by tests