Skip to content

Commit 6996544

Browse files
committed
fix(kafka): update security protocol to use default configuration
1 parent 790b7c5 commit 6996544

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

plugin-server/src/kafka/consumer.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ export class KafkaConsumer {
131131

132132
this.consumerConfig = {
133133
'client.id': hostname(),
134-
'security.protocol': 'plaintext',
134+
'security.protocol': defaultConfig.KAFKA_SECURITY_PROTOCOL,
135135
'metadata.broker.list': 'kafka:9092', // Overridden with KAFKA_CONSUMER_METADATA_BROKER_LIST
136136
log_level: 4, // WARN as the default
137137
'group.id': this.config.groupId,

0 commit comments

Comments
 (0)