Nelson

@flo076 did you figure out ? I have the same problem #80 ...

RabbitMQ sucks with Spark Streaming. - Solution 1 => Use Kafka - Solution 2 => you will have to live with that kind of errors (and many more ...)

too many ... - timeouts - connection closed - messages lost - poor performance (when overload) - ....

+1 got it too. I made a quick fix with a Thread that force to close "unused connection".

`if (useSslConnection(params)) { factory.useSslProtocol(getSslProtocol(params)) }` shouldn't it be in the addConnection instead of the getChannel ?