---
apiVersion: core.oam.dev/v1beta1
kind: Application
metadata:
  name: messaging-kafka-demo
  annotations:
    version: v0.0.1
    description: |
      Echo demo in Rust, using the WebAssembly Component Model and WebAssembly Interfaces Types (WIT), along with
      the Kafka messaging provider.
spec:
  components:
    - name: echo
      type: component
      properties:
        image: file://./build/echo_messaging_s.wasm
      traits:
        # Govern the spread/scheduling of the component
        - type: spreadscaler
          properties:
            instances: 1
        - type: link
          properties:
            target: kafka
            namespace: wasmcloud
            package: messaging
            interfaces: [consumer]
            target_config:
              - name: simple-subscription
                properties:
                  topic: wasmcloud.echo
                  # consumer_group: "your-group-name-here"
                  # consumer_partitions: "0,1,2,3"
                  # producer_partitions: "0,1,2,3"

    # Add a capability provider that implements `wasmcloud:messaging` using KAFKA
    - name: kafka
      type: capability
      properties:
        # To use the locally built version of this provider,
        #
        # - build it with (`cargo build`)
        # - create a provider archive (`wash par create`)
        # - uncomment the line below
        #
        # image: file://../../messaging-kafka-provider.par.gz
        image: ghcr.io/wasmcloud/messaging-kafka:0.5.1