Skip to content

Commit de0b1f5

Browse files
committed
Uses node name as key so we can preserver ordering
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.
1 parent 97f446d commit de0b1f5

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

logs-streaming/logs-kube-kafka-raw.yml

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,12 @@ spec:
2424
terminationGracePeriodSeconds: 5
2525
containers:
2626
- name: kafkacat
27-
image: solsson/kafkacat@sha256:ebebf47061300b14a4b4c2e1e4303ab29f65e4b95d34af1b14bb8f7ec6da7cef
27+
image: solsson/kafkacat-fixedkey@sha256:c9c78aef3090519b64ecc279c06df6914c94720a27469200c079f1871b10fa8f
28+
env:
29+
- name: NODE_NAME
30+
valueFrom:
31+
fieldRef:
32+
fieldPath: spec.nodeName
2833
command:
2934
- sh
3035
- -ec
@@ -43,6 +48,7 @@ spec:
4348
-z snappy
4449
-v
4550
-d broker,topic
51+
-F $NODE_NAME
4652
livenessProbe:
4753
exec:
4854
command:

0 commit comments

Comments
 (0)