#
# Apache Camel AWS Kinesis Source
#
apiVersion: sources.knative.dev/v1alpha1
kind: CamelSource
metadata:
  name: camel-aws-kinesis-source
spec:
  source:
    integration:
      configuration:
        # What other types do we have?
        - type: secret
          value: aws-kinesis
        - type: property
          value: amazon.host=localstack:4568
        - type: property
          value: camel.component.aws-kinesis.configuration=#class:org.apache.camel.k.examples.CustomKinesisConfiguration
      dependencies:
        # Needed for the json part on the flow/steps below
        - camel:jackson
        # Needed for the component
        #
        # NOTE: the dependencies used by the source may change under different
        # circumstances. In the case of this example, it is showing how to use a
        # LocalStack instance to simulate a AWS Kinesis stream, which is useful for
        # testing. In this case, one of the things that the custom client does is
        # disabling cbor so that the response is parseable.
        # However, when pointing to a real AWS Kinesis instance it may be necessary to
        # adjust the dependencies so that jackson-dataformat-cbor is included on the
        # dependencies. As a general recommendation, checking the example
        # 04-aws-kinesis-source-basic which targets AWS Kinesis is also recommended to
        # verify what dependencies, restrictions or requirements apply when using an
        # actual AWS Kinesis instance.
        - camel:camel-aws-kinesis
        # Provides the custom Kinesis configuration
        - mvn:org.apache.camel.k.examples/custom-kinesis-configuration:1.0.3
    flow:
      from:
        uri: aws-kinesis:stream
        parameters:
          secretKey: "{{aws.kinesis.secretKey}}"
          accessKey: "{{aws.kinesis.accessKey}}"
        steps:
        - to: "log:received?showAll=true&multiline=true"
        - marshal:
            json: {}
  sink:
    ref:
      apiVersion: messaging.knative.dev/v1beta1
      kind: InMemoryChannel
      name: aws-kinesis