aboutsummaryrefslogtreecommitdiff
path: root/events-kube/events-kube-kafka.yml
diff options
context:
space:
mode:
authorStaffan Olsson <staffan@repos.se>2017-10-27 08:33:39 +0200
committerStaffan Olsson <staffan@repos.se>2017-10-27 08:33:39 +0200
commit071f973fd2210cb5dc3edca17682e4b520b68b71 (patch)
tree28f219c620980f62a95606335e97b5fe4e38f4a6 /events-kube/events-kube-kafka.yml
parentfc5a8362abda5e5e92df00d7bce21b3f5a7ee280 (diff)
downloadkubernetes-kafka-071f973fd2210cb5dc3edca17682e4b520b68b71.tar.gz
kubernetes-kafka-071f973fd2210cb5dc3edca17682e4b520b68b71.tar.bz2
kubernetes-kafka-071f973fd2210cb5dc3edca17682e4b520b68b71.zip
Manifests updated to 1.8 and v3.0.0 pre-merge
Diffstat (limited to 'events-kube/events-kube-kafka.yml')
-rw-r--r--events-kube/events-kube-kafka.yml51
1 files changed, 51 insertions, 0 deletions
diff --git a/events-kube/events-kube-kafka.yml b/events-kube/events-kube-kafka.yml
new file mode 100644
index 0000000..769fad1
--- /dev/null
+++ b/events-kube/events-kube-kafka.yml
@@ -0,0 +1,51 @@
+apiVersion: extensions/v1beta2
+kind: Deployment
+metadata:
+ name: events-kube-kafka
+ namespace: kafka
+spec:
+ replicas: 1
+ strategy:
+ type: RollingUpdate
+ rollingUpdate:
+ # prefer duplicate events over missed
+ maxUnavailable: 0
+ maxSurge: 1
+ selector:
+ matchLabels:
+ app: events
+ from: kube
+ to: kafka
+ template:
+ metadata:
+ labels:
+ app: events
+ from: kube
+ to: kafka
+ spec:
+ containers:
+ - name: kafkacat-curl
+ image: solsson/kafkacat-curl@sha256:6ad61f2e6343359c3972d7a86815568c0a1d0560068134c5d702a152eb5123a0
+ env:
+ - name: BOOTSTRAP
+ value: kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092
+ - name: TOPIC
+ value: ops-kube-events-all-json-001
+ command:
+ - /bin/bash
+ - -ec
+ - >
+ curl
+ -f
+ -s
+ --cacert /run/secrets/kubernetes.io/serviceaccount/ca.crt
+ --header "Authorization: Bearer $(cat /run/secrets/kubernetes.io/serviceaccount/token)"
+ https://$KUBERNETES_SERVICE_HOST:$KUBERNETES_SERVICE_PORT/api/v1/watch/events
+ |
+ kafkacat
+ -b $BOOTSTRAP
+ -t $TOPIC
+ -P
+ -z snappy
+ -v
+ -d broker,topic