我正在使用Node,并且在我的PC上安装了bootstrap.servers=hostname1:9093
listeners=http://0.0.0.0:8088
ksql.logging.processing.topic.auto.create=true
ksql.logging.processing.stream.auto.create=true
#ksql.schema.registry.url=?
ksql.security.protocol=ssl
ksql.ssl.keystore.location=/root/.kafka/kafka.server.keystore.jks
ksql.ssl.keystore.password=password
ksql.ssl.key.password=password
ksql.ssl.client.auth=true
ksql.streams.state.dir=/etc/ksql/
ksql.ssl.truststore.location=/root/.kafka/kafka.server.truststore.jks
ksql.ssl.truststore.password=password
ERROR:
[
2019-11-12 14:17:27,790] ERROR Failed to start KSQL (io.confluent.ksql.rest.server.KsqlServerMain:62)
io.confluent.ksql.util.KsqlServerException: Could not get Kafka cluster configuration!
at io.confluent.ksql.services.KafkaClusterUtil.getconfig(KafkaClusterUtil.java:77)
at io.confluent.ksql.engine.TopicaccessValidatorFactory.isKafkaAuthorizerEnabled(TopicaccessValidatorFactory.java:66)
at io.confluent.ksql.engine.TopicaccessValidatorFactory.create(TopicaccessValidatorFactory.java:50)
at io.confluent.ksql.rest.server.KsqlRestApplication.buildApplication(KsqlRestApplication.java:505)
at io.confluent.ksql.rest.server.KsqlRestApplication.buildApplication(KsqlRestApplication.java:444)
at io.confluent.ksql.rest.server.KsqlServerMain.createExecutable(KsqlServerMain.java:94)
at io.confluent.ksql.rest.server.KsqlServerMain.main(KsqlServerMain.java:59)
Caused by: java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
at org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow(KafkaFutureImpl.java:45)
at org.apache.kafka.common.internals.KafkaFutureImpl.access$000(KafkaFutureImpl.java:32)
at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:89)
at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:260)
at io.confluent.ksql.services.KafkaClusterUtil.getconfig(KafkaClusterUtil.java:55)
... 6 more
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment.
,并将一个虚拟环境变量(API_KEY = 43783283287)存储在.env文件中。
还请考虑以下文件的路径(如果有帮助的话):
- app.js存储在bloccit / src / app.js
- .env存储在bloccit / .env 中
- main-config.js存储在bloccit \ src \ config \ main-config.js
要获得完整图片,这也是代码提取
main-config.js:
dotenv
app.js:
require("dotenv").config()
const path = require("path");
const viewsFolder = path.join(__dirname,"..","views");
.env:
const express = require("express");
const app = express();
const appConfig = require("./config/main-config.js");
console.log(process.env); //returns windows environment variables
console.log(process.env.API_KEY); //returns undefined
const routeConfig = require("./config/route-config.js");
appConfig.init(app,express);
routeConfig.init(app);
module.exports = app;
问题:当我运行app.js文件(包括API_KEY=43783283287
)时,我得到了所有Windows环境变量的列表(请参见下图),但是在列表中没有看到我的API_KEY。
此外,如果我执行console.log(process.env)
,它将返回console.log(process.env.API_KEY)
。
我在做什么错?