14 lines
479 B
JavaScript
14 lines
479 B
JavaScript
|
import dotenv from 'dotenv';
|
||
|
|
|
||
|
|
dotenv.config();
|
||
|
|
|
||
|
|
const baseGroupId = process.env.KAFKA_GROUP_ID || 'bls-upgrade-consumer';
|
||
|
|
const testGroupId = process.env.KAFKA_TEST_GROUP_ID || `${baseGroupId}-test-${Date.now()}`;
|
||
|
|
|
||
|
|
process.env.KAFKA_GROUP_ID = testGroupId;
|
||
|
|
process.env.KAFKA_FROM_OFFSET = process.env.KAFKA_FROM_OFFSET || 'earliest';
|
||
|
|
|
||
|
|
console.log(`[test-consumer] groupId=${process.env.KAFKA_GROUP_ID}, fromOffset=${process.env.KAFKA_FROM_OFFSET}`);
|
||
|
|
|
||
|
|
await import('./index.js');
|