APIs for Data-in-Motion

Declaratively Defined Event-driven APIs

• 1

  Start Zilla

  Get started by either running pre-configured Zilla examples or docker pull and create your ownconfiguration.

  $ docker pull ghcr.io/aklivity/zilla
  
• 2

  Connect your Kafka

  Connect Zilla to your Kafka. Zilla works with open source and all vendor-offered Kafka deployments.

  zilla.yaml

  #Connect Zilla to any open source or vendor Kafka
     ...
     kafka_client:
       type: kafka
       kind: client
       exit: tcp_client
     tcp_client:
       type: tcp
       kind: client
       options:
         host: YOUR_KAFKA_HOSTNAME
         port: YOUR_KAFKA_PORT
        routes:
           - when:
             - cidr: 0.0.0.0/0
  
• 3

  Configure & Secure API endpoints

  Configure an idempotent REST API that supports HTTP request-response interactions with a Kafka service. Then set up a Server Sent Events (SSE) endpoint to reliably stream the service’s snapshots and events across the web. Wrap everything up by securing your REST and SSE endpoints with JWT access tokens. Continue exploring the Zilla Quickstarts ➔

  zilla.yaml

  HTTP

  SSE

  #Request-Response over Kafka with idempotency
     ...
     http_kafka_proxy:
       type: http-kafka
       kind: proxy,
       routes:
          - when:
             method: POST,
             path: /YOUR_API
          exit: kafka_cache_client,
          with:
            capability: produce
            topic: COMMANDS_KAFKA_TOPIC,
            key: ${idempotencyKey}
  ‍           reply-to: REPLIES_KAFKA_TOPIC,
              overrides:
                zilla:domain-model: CREATE
          - when:
             method: DELETE
             path: /YOUR_API
          exit: kafka_cache_client
          with:
             capability: produce
             topic: COMMANDS_KAFKA_TOPIC
             key: ${idempotencyKey}"
  ‍            reply-to: REPLIES_KAFKA_TOPIC
               overrides:
                 zilla:domain-model: DELETE
  

  #Expose a Kafka topic via an SSE endpoint
     ...
     sse_kafka_proxy:
       type: sse-kafka
       kind: proxy
       routes:
          - when:
             - path: /YOUR_API
          exit: kafka_cache_client
          with:
             topic: SNAPSHOTS_KAFKA_TOPIC
             event:
  ‍             id: '[\"${base64(key)}\",\"${etag}\"]'‍