flume-ng-rabbitmq

flume-ng-rabbitmq copied to clipboard

sink exchange should be exchangename

1

timeLessmeng

Consumer reports an error during consuming rabbit messages, but the exception handling mechanism went into infinite recursion loop. ` 2018-03-06 12:48:45,930 ERROR org.apache.flume.source.rabbitmq.RabbitMQSource: sourceName - Exception thrown while pulling from...

kalondar

Add functionality to exchange name and queue name. With this you can specify dynamically the exchange and queue name like "name_%{header_field}"

rsrdesarrollo

Issues with read performance

5

I'm not sure if I'm missing something but I'm only able to pull somewhere between 10-50 messages/second from my RMQ source but I'm able to get in the range of...

eoglethorpe

Enable process event to specific channels, by name. Everything is documented at the Readme file.

galando

Enable Basic SSL support

6

Enable basic SSL support. Essentially just uncomments the code in `RabbitMQUtil.java` Further work should pass extra configuration options to the SSL library.

daurnimator

[](https://infosecwriteups.com/want-to-take-over-the-java-ecosystem-all-you-need-is-a-mitm-1fc329d898fb) --- This is a security fix for a high severity vulnerability in your [Apache Maven](https://maven.apache.org/) `pom.xml` file(s). The build files indicate that this project is resolving dependencies over HTTP...

JLLeitschuh