spark-rabbitmq
spark-rabbitmq copied to clipboard
Stratio
RabbitMQ Spark Streaming receiver
Hello, Im trying to read data from rabbitmq in databricks. below is the code. def onStart() { // Start the thread that receives data over a connection new Thread("Socket Receiver")...
org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in stage 0.0 failed 1 times, most recent failure: Lost task 0.0 in stage 0.0 (TID 0, localhost, executor driver): java.lang.AbstractMethodError...
For a proof of concept, I created a docker instance of RabbitMq3.8.4 to which I submitted some helloworld style messages in queue "hello". I would like to see those in...
Currently there seems to be no option to use an SSL connection. We would need a new connection parameter called `sslProtocol` or something. When this parameter is set we'll need...
I couldn't find how to acknowledge a message, suggestion ? channel.basicAck(...)
Why i am getting the issue while trying to connect with rabbit mq [ActorRabbitMQSystem-akka.actor.default-dispatcher-2] [akka://ActorRabbitMQSystem/user/$a] connection failed java.net.ConnectException: Connection refused: connect
i simply took the code and try to connect but not able to connect and get the below error [akka://ActorRabbitMQSystem/user/$a] connection failed java.net.ConnectException: Connection refused: connect
