Commit 3affe7d
committed
Enable kafka sink integration tests as a github workflow action
Signed-off-by: Taylor Gray <tylgry@amazon.com>1 parent 332c4ce commit 3affe7d
380 files changed
Lines changed: 6442 additions & 1 deletion
File tree
- .github/workflows
- data-prepper-plugins
- .settings
- aggregate-processor
- .settings
- anomaly-detector-processor
- .settings
- armeria-common
- .settings
- avro-codecs
- .settings
- aws-lambda
- .settings
- aws-plugin-api
- .settings
- aws-plugin
- .settings
- aws-sqs-common
- .settings
- blocking-buffer
- .settings
- buffer-common
- .settings
- cloudwatch-logs
- .settings
- common
- .settings
- csv-processor
- .settings
- date-processor
- .settings
- decompress-processor
- .settings
- detect-format-processor
- .settings
- dissect-processor
- .settings
- drop-events-processor
- .settings
- dynamodb-source-coordination-store
- .settings
- dynamodb-source
- .settings
- encryption-plugin
- .settings
- event-json-codecs
- .settings
- failures-common
- .settings
- flatten-processor
- .settings
- geoip-processor
- .settings
- grok-processor
- .settings
- http-common
- .settings
- http-source-common
- .settings
- http-source
- .settings
- iceberg-source
- .settings
- in-memory-source-coordination-store
- .settings
- kafka-plugins
- .settings
- src/integrationTest/java/org/opensearch/dataprepper/plugins/kafka/sink
- key-value-processor
- .settings
- kinesis-source
- .settings
- log-generator-source
- .settings
- mapdb-processor-state
- .settings
- ml-inference-processor
- .settings
- mongodb
- .settings
- mutate-event-processors
- .settings
- mutate-string-processors
- .settings
- newline-codecs
- .settings
- obfuscate-processor
- .settings
- ocsf
- .settings
- opensearch-api-source
- .settings
- opensearch
- .settings
- otel-apm-service-map-processor
- .settings
- otel-logs-source
- .settings
- otel-metrics-raw-processor
- .settings
- otel-metrics-source
- .settings
- otel-proto-common
- .settings
- otel-trace-group-processor
- .settings
- otel-trace-raw-processor
- .settings
- otel-trace-source
- .settings
- otlp-sink
- .settings
- otlp-source
- .settings
- parquet-codecs
- .settings
- parse-json-processor
- .settings
- personalize-sink
- .settings
- prometheus-sink
- .settings
- prometheus-source
- .settings
- rds-source
- .settings
- rss-source
- .settings
- s3-common
- .settings
- s3-enrich-processor
- .settings
- s3-sink
- .settings
- s3-source
- .settings
- saas-source-plugins
- .settings
- atlassian-commons
- .settings
- confluence-source
- .settings
- crowdstrike-source
- .settings
- jira-source
- .settings
- microsoft-office365-source
- .settings
- source-crawler
- .settings
- service-map-stateful
- .settings
- split-event-processor
- .settings
- sqs-common
- .settings
- sqs-sink
- .settings
- sqs-source
- .settings
- trace-peer-forwarder-processor
- .settings
- translate-processor
- .settings
- truncate-processor
- .settings
- user-agent-processor
- .settings
- write-json-processor
- .settings
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
66 | 66 | | |
67 | 67 | | |
68 | 68 | | |
69 | | - | |
| 69 | + | |
| 70 | + | |
70 | 71 | | |
71 | 72 | | |
72 | 73 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
Lines changed: 2 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
Lines changed: 4 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
Lines changed: 32 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
0 commit comments