This commit is contained in:
parent
f35f64513f
commit
8b58681c35
2 changed files with 12 additions and 4 deletions
|
|
@ -1,8 +1,12 @@
|
|||
import { Kafka } from 'kafkajs';
|
||||
import { Kafka, logLevel } from 'kafkajs';
|
||||
import { serializeError } from '../../core/log.mjs';
|
||||
|
||||
function createKafka({ brokers = ['127.0.0.1:9092'], clientId = 'unrip' } = {}) {
|
||||
return new Kafka({ clientId, brokers });
|
||||
return new Kafka({
|
||||
clientId,
|
||||
brokers,
|
||||
logLevel: logLevel.NOTHING,
|
||||
});
|
||||
}
|
||||
|
||||
export async function createConsumer({ groupId, logger, ...options }) {
|
||||
|
|
|
|||
|
|
@ -1,8 +1,12 @@
|
|||
import { Kafka } from 'kafkajs';
|
||||
import { Kafka, logLevel } from 'kafkajs';
|
||||
import { serializeError } from '../../core/log.mjs';
|
||||
|
||||
function createKafka({ brokers = ['127.0.0.1:9092'], clientId = 'unrip' } = {}) {
|
||||
return new Kafka({ clientId, brokers });
|
||||
return new Kafka({
|
||||
clientId,
|
||||
brokers,
|
||||
logLevel: logLevel.NOTHING,
|
||||
});
|
||||
}
|
||||
|
||||
export async function createProducer({ logger, ...options } = {}) {
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue