File tree Expand file tree Collapse file tree 1 file changed +8
-8
lines changed Expand file tree Collapse file tree 1 file changed +8
-8
lines changed Original file line number Diff line number Diff line change 1
1
---
2
2
kind : ConfigMap
3
3
metadata :
4
- name : test-basic-with- kafkacat
4
+ name : test-kafkacat
5
5
namespace : test-kafka
6
6
apiVersion : v1
7
7
data :
45
45
fi
46
46
47
47
# get info about this message
48
- kafkacat -Q -b $BOOTSTRAP -t test-basic-with- kafkacat:0:$LAST_TS \
48
+ kafkacat -Q -b $BOOTSTRAP -t test-kafkacat:0:$LAST_TS \
49
49
-X socket.timeout.ms=600 -X session.timeout.ms=300 -X request.timeout.ms=50 -X metadata.request.timeout.ms=600
50
50
[ $? -eq 0 ] || echo "At $(date +%FT%H:%M:%S.%3N) bootstrap broker(s) might be down"
51
51
# but don't fail the test; producer and consumer should keep going if there are other brokers
63
63
apiVersion : batch/v1
64
64
kind : Job
65
65
metadata :
66
- name : test-basic-with- kafkacat
66
+ name : test-kafkacat
67
67
namespace : test-kafka
68
68
spec :
69
69
template :
78
78
- --create
79
79
- --if-not-exists
80
80
- --topic
81
- - test-basic-with- kafkacat
81
+ - test-kafkacat
82
82
- --partitions
83
83
- " 1"
84
84
- --replication-factor
88
88
apiVersion : apps/v1beta2
89
89
kind : Deployment
90
90
metadata :
91
- name : test-basic-with- kafkacat
91
+ name : test-kafkacat
92
92
namespace : test-kafka
93
93
spec :
94
94
replicas : 1
@@ -123,7 +123,7 @@ spec:
123
123
echo "--- start $HOSTNAME $(date --iso-8601='ns' -u) ---" >> /shared/produce.tmp
124
124
;
125
125
tail -f /shared/produce.tmp |
126
- kafkacat -P -b $BOOTSTRAP -t test-basic-with- kafkacat -v -T -d broker -K ':'
126
+ kafkacat -P -b $BOOTSTRAP -t test-kafkacat -v -T -d broker -K ':'
127
127
;
128
128
volumeMounts :
129
129
- name : config
@@ -139,7 +139,7 @@ spec:
139
139
- /bin/bash
140
140
- -cex
141
141
- >
142
- kafkacat -C -b $BOOTSTRAP -t test-basic-with- kafkacat -o -1 -f '%T;%k:%p;%o;%s\n' -u -d broker |
142
+ kafkacat -C -b $BOOTSTRAP -t test-kafkacat -o -1 -f '%T;%k:%p;%o;%s\n' -u -d broker |
143
143
tee /shared/consumed.tmp
144
144
;
145
145
volumeMounts :
@@ -178,6 +178,6 @@ spec:
178
178
volumes :
179
179
- name : config
180
180
configMap :
181
- name : test-basic-with- kafkacat
181
+ name : test-kafkacat
182
182
- name : shared
183
183
emptyDir : {}
You can’t perform that action at this time.
0 commit comments