Skip to content

Commit

Permalink
Uses node name as key so we can preserver ordering
Browse files Browse the repository at this point in the history
Addresses #88 (comment).

I deemed it safe to assume that operational daemonset pods never co-exist on a node.

Tests edenhill/kcat#123,
as does 53f355a.
  • Loading branch information
solsson committed Nov 6, 2017
1 parent 97f446d commit de0b1f5
Showing 1 changed file with 7 additions and 1 deletion.
8 changes: 7 additions & 1 deletion logs-streaming/logs-kube-kafka-raw.yml
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand All @@ -43,6 +48,7 @@ spec:
-z snappy
-v
-d broker,topic
-F $NODE_NAME
livenessProbe:
exec:
command:
Expand Down

0 comments on commit de0b1f5

Please sign in to comment.