Reply
Highlighted
New Contributor
Posts: 4
Registered: ‎07-27-2018

Configuring flume with kafka within CM - is it possible to refernce the kafka cluster ?

Hi

I'm setting up Flume to work with kafka.

Currently I'm setting the following param:

tier1.channels.kafka_chan.kafka.bootstrap.servers = kafka_broker1:9092, kafka_broker2:9092

These brokers are kafka brokers that run via Cloudera Manager service of Kafka.

 

Is it possible to somehow replace these implicitly set hosts to dynamic params that will always be interpreted into the kafka brokers?

Something like $KAFKA_BROKERS?

 

Thanks.