diff options
| author | Staffan Olsson <staffan@repos.se> | 2017-11-06 20:42:06 +0100 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2017-11-06 20:42:08 +0100 |
| commit | de0b1f5ba3f375ad5bbc3e32c6344c01e1537c36 (patch) | |
| tree | ac6e240229ec34208a3dc8ae5b2d54aaa2001225 | |
| parent | 97f446d9d1cdbe36eb208ba188da9b8b358dd5f5 (diff) | |
| download | kubernetes-kafka-de0b1f5ba3f375ad5bbc3e32c6344c01e1537c36.tar.gz kubernetes-kafka-de0b1f5ba3f375ad5bbc3e32c6344c01e1537c36.tar.bz2 kubernetes-kafka-de0b1f5ba3f375ad5bbc3e32c6344c01e1537c36.zip | |
Uses node name as key so we can preserver ordering
Addresses https://github.com/Yolean/kubernetes-kafka/pull/88#issuecomment-341957997.
I deemed it safe to assume that operational daemonset pods never co-exist on a node.
Tests https://github.com/edenhill/kafkacat/pull/123,
as does 53f355a.
| -rw-r--r-- | logs-streaming/logs-kube-kafka-raw.yml | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/logs-streaming/logs-kube-kafka-raw.yml b/logs-streaming/logs-kube-kafka-raw.yml index b697f40..05928e9 100644 --- a/logs-streaming/logs-kube-kafka-raw.yml +++ b/logs-streaming/logs-kube-kafka-raw.yml @@ -24,7 +24,12 @@ spec: terminationGracePeriodSeconds: 5 containers: - name: kafkacat - image: solsson/kafkacat@sha256:ebebf47061300b14a4b4c2e1e4303ab29f65e4b95d34af1b14bb8f7ec6da7cef + image: solsson/kafkacat-fixedkey@sha256:c9c78aef3090519b64ecc279c06df6914c94720a27469200c079f1871b10fa8f + env: + - name: NODE_NAME + valueFrom: + fieldRef: + fieldPath: spec.nodeName command: - sh - -ec @@ -43,6 +48,7 @@ spec: -z snappy -v -d broker,topic + -F $NODE_NAME livenessProbe: exec: command: |