console logs
This commit is contained in:
@@ -1,3 +1,4 @@
|
||||
WRENCHJOB_PORT=3000
|
||||
WRENCHJOB_POSTGRE_URL='postgresql://wrenchboard:wrenchboard@10.20.30.60:5432/wrenchboard'
|
||||
WRENCHJOB_KAFKA_SERVER='10.10.10.120:9092'
|
||||
WRENCHJOB_KAFKA_BROKER01='10.10.10.120:9092'
|
||||
|
||||
|
||||
@@ -15,12 +15,14 @@ const kafka = new Kafka({
|
||||
class KafkaConfig {
|
||||
|
||||
constructor() {
|
||||
console.log("kafkaBroker1 ******** ", kafkaBroker1);
|
||||
this.producer = kafka.producer();
|
||||
this.consumer = kafka.consumer({ groupId: "test-group" });
|
||||
}
|
||||
|
||||
async produce(topic, messages) {
|
||||
try {
|
||||
console.log("kafkaBroker1 ######### ", kafkaBroker1);
|
||||
await this.producer.connect();
|
||||
await this.producer.send({
|
||||
topic: topic,
|
||||
|
||||
Reference in New Issue
Block a user