fix server
This commit is contained in:
+1
-1
@@ -4,7 +4,7 @@ const kafkaServer = process.env.KAFKA_SERVER;
|
||||
|
||||
const kafka = new Kafka({
|
||||
clientId: "wallet-kafka",
|
||||
brokers: [kafkaServer],
|
||||
brokers: ['10.10.10.120:9092'],
|
||||
});
|
||||
class KafkaConfig {
|
||||
constructor() {
|
||||
|
||||
Reference in New Issue
Block a user