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.

Sign up for GitHub

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 Kinesis plugin support #17615

Merged
merged 8 commits into from
Mar 24, 2025

fix ut

2a99aa4
Select commit
Loading
Failed to load commit list.
Merged

[Pull-based Ingestion] Add Kinesis plugin support #17615

fix ut
2a99aa4
Select commit
Loading
Failed to load commit list.
Codecov / codecov/patch succeeded Mar 21, 2025 in 1s

72.72% of diff hit (target 72.53%)

View this Pull Request on Codecov

72.72% of diff hit (target 72.53%)

Annotations

Check warning on line 142 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#L141-L142 

Added lines #L141 - L142 were not covered by tests

Check warning on line 149 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#L149 

Added line #L149 was not covered by tests

Check warning on line 214 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#L214 

Added line #L214 was not covered by tests

Check warning on line 38 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisConsumerFactory.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisConsumerFactory.java#L38 

Added line #L38 was not covered by tests

Check warning on line 29 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisPlugin.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisPlugin.java#L29 

Added line #L29 was not covered by tests

Check warning on line 34 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisPlugin.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisPlugin.java#L34 

Added line #L34 was not covered by tests

Check warning on line 39 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisPlugin.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisPlugin.java#L39 

Added line #L39 was not covered by tests

Check warning on line 66 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java#L65-L66 

Added lines #L65 - L66 were not covered by tests

Check warning on line 104 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java#L103-L104 

Added lines #L103 - L104 were not covered by tests

Check warning on line 106 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java#L106 

Added line #L106 was not covered by tests

Check warning on line 113 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java#L110-L113 

Added lines #L110 - L113 were not covered by tests

Check warning on line 116 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java#L116 

Added line #L116 was not covered by tests

Check warning on line 139 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java#L139 

Added line #L139 was not covered by tests

Check warning on line 141 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java#L141 

Added line #L141 was not covered by tests

Check warning on line 185 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java#L185 

Added line #L185 was not covered by tests

Check warning on line 203 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/KinesisShardConsumer.java#L203 

Added line #L203 was not covered by tests

Check warning on line 68 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java#L68 

Added line #L68 was not covered by tests

Check warning on line 74 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java#L74 

Added line #L74 was not covered by tests

Check warning on line 77 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java#L77 

Added line #L77 was not covered by tests

Check warning on line 86 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java#L86 

Added line #L86 was not covered by tests

Check warning on line 89 in plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

plugins/ingestion-kinesis/src/main/java/org/opensearch/plugin/kinesis/SequenceNumber.java#L89 

Added line #L89 was not covered by tests

Check warning on line 226 in server/src/main/java/org/opensearch/index/engine/IngestionEngine.java

See this annotation in the file changed.

@codecov codecov / codecov/patch

server/src/main/java/org/opensearch/index/engine/IngestionEngine.java#L226 

Added line #L226 was not covered by tests
View more details on Codecov