radanalyticsio/streaming-amqp

Issues

• Spark 2.4.4 Compatibility

  #36 opened 3 years ago by amitsehgal29
  0

• Spark streaming from RabbitMQ using AMQP

  #33 opened 6 years ago by karyampudi
  6

• Create thin artifact version

  #31 opened 6 years ago by EldritchJS
  0

• Add SSL/TLS support

  #4 opened 8 years ago by ppatierno
  0

• Add AMQP filtering feature

  #9 opened 8 years ago by ppatierno
  0

• Investigating on direct model implementation

  #13 opened 8 years ago by ppatierno
  0

• Investigating on structured stream implementation

  #19 opened 8 years ago by ppatierno
  0

• Add dataframe support

  #30 opened 6 years ago by EldritchJS
  0

• Add SASL PLAIN authentication

  #3 opened 6 years ago by ppatierno
  1

• Investigate None/null/etc. at interface between Python ClassHelper and createStream method.

  #29 opened 6 years ago by EldritchJS
  1

• Should these artifacts be in the "org.apache.spark" group/organization?

  #23 opened 6 years ago by erikerlandson
  5

• Python example with RabbitMQ

  #22 opened 7 years ago by Kexolotl
  1

• --packages install cannot resolve dependencies

  #21 opened 7 years ago by ducktrA
  3

• sbt-spark-package;0.2.4: not found

  #20 opened 8 years ago by jocerfranquiz
  1

• Add Maven as build manager

  #16 opened 8 years ago by ppatierno
  1

• Add tests for JSON message converter use cases

  #18 opened 8 years ago by ppatierno
  0

• Add PySpark support

  #7 opened 8 years ago by ppatierno
  1

• Add backpressure handling

  #10 opened 8 years ago by ppatierno
  1

• Add a message convert from AMQP message to JSON string representation

  #17 opened 8 years ago by ppatierno
  1

• Move to Spark Streaming 2.0.0

  #14 opened 8 years ago by ppatierno
  1

• Add not reliable connector implementation

  #12 opened 8 years ago by ppatierno
  1

• Block not removed from map when deliveries are sent

  #15 opened 8 years ago by ppatierno
  1

• Improve timing for Async flow controller

  #11 opened 8 years ago by ppatierno
  1

• Injection of the AMQP rate controller

  #8 opened 8 years ago by ppatierno
  1

• Move AMQP receiver lifecycle inside rate controller

  #5 opened 8 years ago by ppatierno
  1

• Add a default message converter

  #2 opened 8 years ago by ppatierno
  2

• Throttling end not raised if no messages come

  #6 opened 8 years ago by ppatierno
  1

• Add logging feature

  #1 opened 8 years ago by ppatierno
  1