Skip to content

Commit 352a8d3

Browse files
fix(mock): check value only for certain offsets (#131)
1 parent 34d822b commit 352a8d3

File tree

1 file changed

+10
-1
lines changed

1 file changed

+10
-1
lines changed

packages/api-mock/src/handlers/kafka-admin.js

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,10 +70,19 @@ module.exports = {
7070
const id = c.request.params.consumerGroupId;
7171
const payload = c.request.body;
7272

73-
if (!payload || !payload.length && !payload.offset || !payload.value) {
73+
if (!payload || !payload.length && !payload.offset) {
7474
return res.status(400).json({ error_message: 'missing request body' })
7575
}
7676

77+
78+
if(!payload.value && payload.offset !== "latest" && payload.offset !== "earliest") {
79+
return res.status(400).json({ error_message: `Value has to be set when ${payload.offset} offset is used.`})
80+
}
81+
82+
if((payload.offset === "latest" || payload.offset === "earliest") && payload.value) {
83+
return res.status(400).json({ error_message: `Value can't be used when ${payload.offset} offset is used.`})
84+
}
85+
7786
const group = getConsumerGroup(id);
7887
if (!group) {
7988
return res.status(404).json({ error_message: 'not found' });

0 commit comments

Comments
 (0)