search

apache / rocketmq-externals

Mirror of Apache RocketMQ (Incubating)
4.57k stars 3.07k forks source link

Some improvements about rocketmq-spark #887

Closed zhaorongsheng closed 1 year ago

zhaorongsheng commented 2 years ago

What is the purpose of the change

Here is some improvements about rocketmq-spark

Brief changelog

  1. Fix Checkstyle issues about the following class: RocketMQConfig/MessageSet/DefaultMessageRetryManager/RocketMQReceiver
  2. Bump rocketmq client version from 4.2.0 to 4.9.4
  3. Support custom pull consumer using SPI method with interface MQPullConsumerProviderFactory/MQPullConsumerProvider
  4. Fix the issue about spark streaming job was still running when consumer client failed during start-up process
  5. Improving documentation about direct stream and receiver stream