diff --git a/Cargo.lock b/Cargo.lock new file mode 100644 index 0000000..a9dd94f --- /dev/null +++ b/Cargo.lock @@ -0,0 +1,7 @@ +# This file is automatically @generated by Cargo. +# It is not intended for manual editing. +version = 3 + +[[package]] +name = "rusty-pipe" +version = "0.1.0" diff --git a/src/testdata/config-kinesis-to-kafka.json b/src/testdata/config-kinesis-to-kafka.json new file mode 100644 index 0000000..3a3e669 --- /dev/null +++ b/src/testdata/config-kinesis-to-kafka.json @@ -0,0 +1,21 @@ +{ + "streams": { + "input": { + "engine": { + "type": "kinesis", + "kinesis": { + "aws-region": "us-east-2", + "aws-arn": "arn:aws:::us-east-2" + } + } + }, + "output": { + "engine": { + "type": "kafka", + "kafka": { + "topic": "topic-name" + } + } + } + } +} diff --git a/src/testdata/config-stdin-to-stdout.yaml b/src/testdata/config-stdin-to-stdout.yaml new file mode 100644 index 0000000..9645d31 --- /dev/null +++ b/src/testdata/config-stdin-to-stdout.yaml @@ -0,0 +1,7 @@ +streams: + input: + engine: + type: stdin + output: + engine: + type: stdout