EventHubUtils

This project is a Java (SpringBoot) application that can be used as utility to work with Azure Event Hub. It can be used to send/read messages.

Development

Comands

mvn spring-boot:run

useful links links

test

Swagger UI

Invoke:

curl -X 'POST' -H 'Content-Type: application/json' -d '{
    "idMessage": "64c22c1d668ac678831353113",
    "message": "Hello"
}' -v 'http://localhost:8080/send'

Docker

Build

docker build --build-arg JAR_FILE=target/*.jar -t rmarcello/event-hub-utils:0.0.1 .

more info at https://spring.io/guides/topicals/spring-boot-docker/

Run

docker run -p 8080:8080 -e EVENTHUB_CONNECTION_STRING="Endpoint=sb://<eventhubname>.servicebus.windows.net/;SharedAccessKeyName=<keyname>;SharedAccessKey=<accesskey>;EntityPath=<pathname>" rmarcello/event-hub-utils:0.0.1

Kubernetes

Apply the following descriptor:

apiVersion: v1
kind: Secret
metadata:
  name: event-hub-utils
type: Opaque
stringData:
  EVENTHUB_CONNECTION_STRING: "Endpoint=sb://<eventhubname>.servicebus.windows.net/;SharedAccessKeyName=<keyname>;SharedAccessKey=<accesskey>;EntityPath=<pathname>"
---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: event-hub-utils
spec:
  replicas: 1  # Number of replicas (pods) you want to run
  selector:
    matchLabels:
      app: event-hub-utils
  template:
    metadata:
      labels:
        app: event-hub-utils
    spec:
      containers:
      - name: event-hub-utils
        image: rmarcello/event-hub-utils:0.0.1
        ports:
        - containerPort: 8080  # Port inside the container
        envFrom:
          - secretRef:
              name: event-hub-utils

or simply apply the prepared file:

kubectl apply -f k8s/deploy.yaml

marcelloraffaele/EventHubUtils