Open veve90 opened 6 years ago
Hello,
I am interested in using the AMQP source :)
However, It is hard for me to understand where I should add the configuration:
amqp("exchangeName=exchangeName", "[,host=host] " "[,port=port] " "[,virtualHost=virtualHost] " "[,userName=user] " "[,password=password] " "[,exchangeType=direct] " "[,durableExchange=false] " "[,queueName=queueName] " "[,durableQueue=false] " "[,exclusiveQueue=false] " "[,autoDeleteQueue=false] " "[,bindings=binding1,binding2,bindingN] "[,useMessageTimestamp=false])"
Is it in flume conf?
Thank you!
Are you using the "old" Flume or Flume NG? This is for the older (much older) version of Flume
Hello,
I am interested in using the AMQP source :)
However, It is hard for me to understand where I should add the configuration:
amqp("exchangeName=exchangeName", "[,host=host] " "[,port=port] " "[,virtualHost=virtualHost] " "[,userName=user] " "[,password=password] " "[,exchangeType=direct] " "[,durableExchange=false] " "[,queueName=queueName] " "[,durableQueue=false] " "[,exclusiveQueue=false] " "[,autoDeleteQueue=false] " "[,bindings=binding1,binding2,bindingN] "[,useMessageTimestamp=false])"
Is it in flume conf?
Thank you!