Skip to content

Commit 0f47dbc

Browse files
author
Justin Torre
committed
tmp: disable consuming
1 parent 9be4f28 commit 0f47dbc

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

valhalla/jawn/src/index.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -123,10 +123,10 @@ if (KAFKA_ENABLED) {
123123
backFillCount: 0,
124124
});
125125
startSQSConsumers({
126-
dlqCount: DLQ_WORKER_COUNT,
127-
normalCount: NORMAL_WORKER_COUNT,
128-
scoresCount: SCORES_WORKER_COUNT,
129-
scoresDlqCount: SCORES_WORKER_COUNT,
126+
dlqCount: 0,
127+
normalCount: 0,
128+
scoresCount: 0,
129+
scoresDlqCount: 0,
130130
backFillCount: 0,
131131
});
132132
}
@@ -253,7 +253,7 @@ server.on("upgrade", async (req, socket, head) => {
253253
route: {},
254254
originalUrl: req.url,
255255
baseUrl: "",
256-
next: function () {},
256+
next: function () { },
257257
} as unknown as ExpressRequest;
258258

259259
const { data: requestWrapper, error: requestWrapperErr } =

0 commit comments

Comments
 (0)