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.
mvn spring-boot:run
Invoke:
curl -X 'POST' -H 'Content-Type: application/json' -d '{
"idMessage": "64c22c1d668ac678831353113",
"message": "Hello"
}' -v 'http://localhost:8080/send'
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/
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
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