From de0b1f5ba3f375ad5bbc3e32c6344c01e1537c36 Mon Sep 17 00:00:00 2001
From: Staffan Olsson <staffan@repos.se>
Date: Mon, 6 Nov 2017 20:42:06 +0100
Subject: 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.
---
 logs-streaming/logs-kube-kafka-raw.yml | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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:
-- 
cgit v1.2.3