07-28-2018 03:34 AM
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?