Skip to content

Addon: stream all Kubernetes events to a topic #39

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
wants to merge 8 commits into from
Closed

Addon: stream all Kubernetes events to a topic #39

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
c7c7e9c
Creates a pod for expermentation with kubectl and kafkacat
solsson Jul 6, 2017
bbd8c47
Produces and reads events
solsson Jul 6, 2017
b0a600a
wip
solsson Jul 7, 2017
8c99e81
Quite interesting way to test a command from yaml - see it in logs
solsson Jul 7, 2017
31b8eb2
Produces proper json. Let's see when curl gives up and the container …
solsson Jul 7, 2017
748d408
Testing compression but solsson/kafka:0.11.0.0 throws ...
solsson Jul 7, 2017
b56a8ec
Works with my current kafka image, and the test consumer still sees JSON
solsson Jul 7, 2017
a6bc27f
Latest build suppors snappy compression
solsson Jul 27, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Quite interesting way to test a command from yaml - see it in logs
  • Loading branch information
@solsson
solsson committed Jul 27, 2017
commit 8c99e813c2c0e42a6192e061d43723eb5dc5bfef
4 changes: 3 additions & 1 deletion addon-events/events-kube-kafka.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,14 @@ spec:
- /bin/bash
- -ec
- >
echo '
curl
--cacert /run/secrets/kubernetes.io/serviceaccount/ca.crt
--header "Authorization: Bearer $(cat /run/secrets/kubernetes.io/serviceaccont/token)"
--header "Authorization: Bearer $(cat /run/secrets/kubernetes.io/serviceaccount/token)"
https://$KUBERNETES_SERVICE_HOST:$KUBERNETES_SERVICE_PORT/api/v1/watch/events
|
kafkacat
-b kafka-0.broker.kafka.svc.cluster.local:9092,kafka-1.broker.kafka.svc.cluster.local:9092,kafka-2.broker.kafka.svc.cluster.local:9092
-t ops-kube-events-all-json-001
-P
'; tail -f /dev/null