update kafka client config
This commit is contained in:
@@ -23,12 +23,5 @@ if (!process.env.SKIP_DB_CHECK && !process.env.DATABASE_TYPE) {
|
||||
}
|
||||
|
||||
if (process.env.CLOUD_MODE) {
|
||||
checkMissing([
|
||||
'CLOUD_URL',
|
||||
'KAFKA_BROKER',
|
||||
'KAFKA_URL',
|
||||
'REDIS_URL',
|
||||
'KAFKA_SASL_MECHANISM',
|
||||
'KAFKA_SSL',
|
||||
]);
|
||||
checkMissing(['CLOUD_URL', 'KAFKA_BROKER', 'KAFKA_URL', 'REDIS_URL', 'KAFKA_SASL_MECHANISM']);
|
||||
}
|
||||
|
||||
@@ -12,13 +12,14 @@ const enabled = Boolean(process.env.KAFKA_URL && process.env.KAFKA_BROKER);
|
||||
function getClient() {
|
||||
const { username, password } = new URL(process.env.KAFKA_URL);
|
||||
const brokers = process.env.KAFKA_BROKER.split(',');
|
||||
const sslEnabled = process.env.KAFKA_SSL.toLowerCase() === 'true';
|
||||
const mechanism = process.env.KAFKA_SASL_MECHANISM as 'plain' | 'scram-sha-256' | 'scram-sha-512';
|
||||
|
||||
const ssl: { ssl?: tls.ConnectionOptions | boolean; sasl?: SASLOptions } =
|
||||
username && password
|
||||
? {
|
||||
ssl: sslEnabled,
|
||||
ssl: {
|
||||
rejectUnauthorized: false,
|
||||
},
|
||||
sasl: {
|
||||
mechanism,
|
||||
username,
|
||||
|
||||
Reference in New Issue
Block a user