serverless.yml

service: serverless-kafka
plugins:
  - serverless-python-requirements

provider:
  name: aws
  profile: ${self:custom.profiles.${self:provider.stage}}
  runtime: python3.6
  region: eu-west-1
  memorySize: 128
  timeout: 10
  environment:
    KAFKA_HOSTS: ${env:KAFKA_HOSTS}
    SCHEMA_REGISTRY: ${env:SCHEMA_REGISTRY}

custom:
  defaultStage: dev
  profiles:
    dev: nonprod
    prod: prod

package:
  exclude:
    - .git/**
    - .idea/**
    - .iml
    - node_modules/**
  include:
    - service.cert
    - service.key
    - ca.pem

functions:
  consumer:
    handler: api.consumer.consumer_handler
    events:
      - http:
          path: consume/{topic}
          method: get
      - http:
          path: consume/{topic}/partition/{partition}
          method: get
      - http:
          path: consume/{topic}/partition/{partition}/offset/{offset}
          method: get
  copy:
    handler: api.copy.copy_handler
    events:
      - http:
          path: copy/{from_topic}/{to_topic}
          method: post