Skip to content

Eventrouter Kafka Producer

EventRouter consumer microservice dispatching cloudevents to Kafka.

It expose two endpoints:

  • /healthz - health check endpoint (GET)
  • /handle - eventrouter hook endpoint (POST)

How to install

$ helm repo add krateo https://charts.krateo.io
$ helm repo update krateo
$ helm install eventrouter-kafka-producer krateo/eventrouter-kafka-producer --namespace krateo-system --create-namespace

Env Vars

Name Description Default Value
EVENTROUTER_KAFKA_PRODUCER_PORT port to listen on 8080
EVENTROUTER_KAFKA_PRODUCER_DEBUG dump verbose output false
EVENTROUTER_KAFKA_PRODUCER_BROKERS comma separated list of kafka brokers 127.0.0.1:9092
EVENTROUTER_KAFKA_PRODUCER_TOPIC send events to this Kafka topic test-topic

Registering with the EventRouter

To register this service with the eventrouter apply a manifest like this:

cat <<EOF | kubectl apply -f -
apiVersion: eventrouter.krateo.io/v1alpha1
kind: Registration
metadata:
  name: kafka-producer-registration
spec:
  serviceName: Kafka Producer
  # Your custom hook service endpoint
  endpoint: https://this.service.addr:8080/handle
EOF