We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6996544 commit 4aa5b4eCopy full SHA for 4aa5b4e
plugin-server/src/kafka/consumer.ts
@@ -132,7 +132,7 @@ export class KafkaConsumer {
132
this.consumerConfig = {
133
'client.id': hostname(),
134
'security.protocol': defaultConfig.KAFKA_SECURITY_PROTOCOL,
135
- 'metadata.broker.list': 'kafka:9092', // Overridden with KAFKA_CONSUMER_METADATA_BROKER_LIST
+ 'metadata.broker.list': defaultConfig.KAFKA_HOSTS, // Overridden with KAFKA_CONSUMER_METADATA_BROKER_LIST
136
log_level: 4, // WARN as the default
137
'group.id': this.config.groupId,
138
'session.timeout.ms': 30_000,
0 commit comments