kafka config
This commit is contained in:
@@ -1,2 +1,3 @@
|
||||
WRENCHJOB_PORT=3000
|
||||
WRENCHJOB_POSTGRE_URL='postgresql://wrenchboard:wrenchboard@10.20.30.60:5432/wrenchboard'
|
||||
WRENCHJOB_KAFKA_SERVER='10.10.10.120:9092'
|
||||
|
||||
+3
-2
@@ -1,9 +1,10 @@
|
||||
// import { Kafka } from "kafkajs";
|
||||
const {Kafka} = require('kafkajs');
|
||||
const kafkaServer = process.env.KAFKA_SERVER;
|
||||
|
||||
const kafka = new Kafka({
|
||||
clientId: "nodejs-kafka",
|
||||
brokers: ["10.10.10.120:9092"],
|
||||
clientId: "wallet-kafka",
|
||||
brokers: [kafkaServer],
|
||||
});
|
||||
class KafkaConfig {
|
||||
constructor() {
|
||||
|
||||
Reference in New Issue
Block a user