Google Git
Sign in
apache / flink-connector-rabbitmq / HEAD
  1. 66e323a [FLINK-35174][Connectors/RabbitMQ] Bump commons-compress to 1.26.1 by Danny Cranmer · 7 days ago main
  2. 8e8a022 [FLINK-35142][Connectors/RabbitMQ] Drop support for Flink 1.17 by Danny Cranmer · 7 days ago
  3. 6b8a906 [hotfix] Fix the dependency convergence rule by Hang Ruan · 3 months ago
  4. ddbfa8f [hotfix] Update copyright year to 2024 by Hang Ruan · 3 months ago
  5. 1b0e2a8 [hotfix] Bump version to 3.1-SNAPSHOT by Danny Cranmer · 7 days ago
  6. b62e491 [FLINK-34961] Use dedicated CI name for Rabbit MQ connector to differentiate it in infra-reports by Sergey Nuyanzin · 13 days ago
  7. 3d717b2 [hotfix] Update Flink version for weekly tests from 1.16.2 to 1.16.3 and from 1.17.1 to 1.17.2 by Martijn Visser · 4 months ago
  8. 33d125f [FLINK-34020] Bump CI flink version on flink-connector-rabbitmq. This closes #22 by Martijn Visser · 4 months ago
  9. 427bf4c [FLINK-34019] Bump com.rabbitmq:amqp-client from 5.13.1 to 5.20.0. This closes #18 by dependabot[bot] · 4 months ago
  10. 7203c95 [FLINK-26907] RMQSourceITCase failed on Azure due to container startup failed. This closes #20 by yuxiang · 4 months ago
  11. fb0566a [FLINK-30400][build] Stop bundling flink-connector-base. This closes #17 by Hang Ruan · 6 months ago
  12. 9af1fd8 [hotfix] Update NOTICE files to reflect year 2023. This closes #15 by Hang Ruan · 6 months ago
  13. 6b70965 [FLINK-31923] Run nightly builds against multiple branches and Flink versions by Martijn Visser · 11 months ago
  14. 9d5b392 [FLINK-32024][docs] Short code related to externalized connector retrieve version from its own data yaml by Weijie Guo · 12 months ago
  15. 6aec8ee [hotfix] Fix incorrect connector artifact name by Weijie Guo · 12 months ago
  16. a247b2c [hotfix] Python connector download link should refer to the url defined in externalized repository by Weijie Guo · 12 months ago
  17. c354730 [FLINK-31759][rabbitmq] Update some external connectors to use sql_connector_download_table and connector_artifact shortcode by Weijie Guo · 1 year, 1 month ago
  18. ab920cb [FLINK-31701][Connector/RabbitMQ] Remove versioned dependency on Archunit by Martijn Visser · 1 year, 1 month ago
  19. a742d30 [hotfix] Set correct `japicmp.referenceVersion` by Martijn Visser · 1 year, 1 month ago
  20. 64bdc46 [hotfix] Use `org.apache.flink` for `flink-connector-parent` by Martijn Visser · 1 year, 1 month ago
  21. 0a4c5be [FLINK-31701][Connector/RabbitMQ] Set `japicmp.referenceVersion` to the version of the latest released connector by Martijn Visser · 1 year, 1 month ago
  22. c5ee71a [hotfix] Allow manual triggering of nightly builds by Martijn Visser · 1 year, 1 month ago
  23. 2c0afa4 [FLINK-31701][Connector/RabbitMQ] Upgrade Archunit to 1.0.0 by Martijn Visser · 1 year, 1 month ago
  24. 4b2a198 [FLINK-31701][Connector/RabbitMQ] Upgrade and sync related dependencies from Flink 1.16.0 to Flink 1.17.0 / Flink 1.17.0-SNAPSHOT by Martijn Visser · 1 year, 1 month ago
  25. 650e8fc [FLINK-31701][Connector/RabbitMQ] Include local `DockerImageVersions` instead of relying on the one from the Flink repository by Martijn Visser · 1 year, 1 month ago
  26. eab2cab [hotfix] Add release workflow to build against final versions by Danny Cranmer · 1 year, 1 month ago
  27. 36ad9d5 [hotfix] Disable nighty dependency convergence (#6) by Danny Cranmer · 1 year, 1 month ago
  28. b5f30ad [FLINK-30963][ci] Streamline binary URL configuration by Chesnay Schepler · 1 year, 3 months ago
  29. 967f713 [FLINK-30417][Connectors/RabbitMQ] Add "RabbitMQ" to the error while creating the channel and failing. This closes #4 by Yaron Shani · 1 year, 4 months ago
  30. 25a71a7 [hotfix] Update NOTICE by Martijn Visser · 1 year, 4 months ago
  31. 81d03b8 [hotfix] Reuse workflow by Chesnay Schepler · 1 year, 5 months ago
  32. 7ac1126 [hotfix][ci] Remove repo name from workflow files by Chesnay Schepler · 1 year, 5 months ago
  33. 50502f4 [hotfix][ci] Only run weekly in Apache repo by Chesnay Schepler · 1 year, 5 months ago
  34. 711dee3 [FLINK-30353][ci] Limit concurrency by Chesnay Schepler · 1 year, 5 months ago
  35. 972fc15 [hotfix] Update README by Martijn Visser · 1 year, 5 months ago
  36. 70409b8 [FLINK-30279][Archunit] Add Archunit rule violations by Martijn Visser · 1 year, 5 months ago
  37. a80c0f4 [FLINK-30279][Connector/RabbitMQ] Move existing RabbitMQ connector code from Flink repo to dedicated RabbitMQ repo by Martijn Visser · 1 year, 5 months ago
  38. 6ed8fdb [FLINK-25868][build] Disable japicmp in packaging/e2e modules by Chesnay Schepler · 2 years, 3 months ago
  39. 6272125 [FLINK-28676] Update copyright year to 2014-2022 in NOTICE files by Benchao Li · 1 year, 9 months ago
  40. c688609 [FLINK-28904][python][docs] Add missing connector/format documentation by Juntao Hu · 1 year, 9 months ago
  41. c0c65d4 [FLINK-28140][python][docs] Improve the documentation connector pages and metrics pages by Mingde Peng · 1 year, 9 months ago
  42. 7b2b79a [FLINK-24721][build] Remove unnecessary relativePath to parent by Chesnay Schepler · 2 years ago
  43. d27d589 [FLINK-26616][tests] Remove deadlines from CommonTestUtils by Chesnay Schepler · 2 years, 1 month ago
  44. 092e9e9 [FLINK-26578][docs-zh] Translate new Project Configuration section to Chinese. This closes #19100 by Yubin Li · 2 years, 1 month ago
  45. 94d3e2d Update version to 1.16-SNAPSHOT by Yun Gao · 2 years, 1 month ago
  46. b094ff9 [FLINK-26294][test] Using fixed description for ArchUnit ITCaseRules by Jing Ge · 2 years, 2 months ago
  47. 5057517 [hotfix] Fix JUnit 5 mini cluster arch unit rules by Dawid Wysakowicz · 2 years, 2 months ago
  48. 3b57c34 [FLINK-25892][rabbitmq][test] add ArchUnit tests for test code by Jing Ge · 2 years, 3 months ago
  49. 8b4fdf0 [FLINK-25129][docs] Restructure project configuation pages by Daisy T · 2 years, 3 months ago
  50. fb666d1 [FLINK-25744] Support native savepoints by Dawid Wysakowicz · 2 years, 3 months ago
  51. 1ec28f4 [hotfix][connectors] Every connector now shades the flink-connector-base in its uber jar by slinkydeveloper · 2 years, 5 months ago
  52. 0f5bca9 [Hotfix] Fix typos. by Roc Marshal · 2 years, 7 months ago
  53. 5efb318 [FLINK-25039][build] Disable shading of test jar by default by Chesnay Schepler · 2 years, 5 months ago
  54. 2d9c644 [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck test by Michal Ciesielczyk · 2 years, 6 months ago
  55. 798904a [FLINK-24816][rabbitmq] Bump amqp-client to v5.13.1 by martijnvisser · 2 years, 6 months ago
  56. 663476c [FLINK-24806][connectors/rabbitmq] Fix container startup in RMQSourceITCase by Michal Ciesielczyk · 2 years, 6 months ago
  57. 162eae3 [FLINK-24018][build] Remove Scala dependencies from Java APIs by Chesnay Schepler · 2 years, 6 months ago
  58. c236a9d [FLINK-23651][python] Support RabbitMQ in PyFlink by Eelis Kostiainen · 2 years, 9 months ago
  59. 09d9579 [FLINK-23607][state/changelog] Make Changelog Backend a transitive dependency by Roman Khachatryan · 2 years, 8 months ago
  60. d2d9dfb [FLINK-23859] Fix typos by hapihu · 2 years, 8 months ago
  61. 2cfebf7 Update version to 1.15-SNAPSHOT by Xintong Song · 2 years, 8 months ago
  62. 70966aa [hotfix][test/testcontainers] Use Testcontainer BOM to manage versions in the project by Qingsheng Ren · 2 years, 9 months ago
  63. e645137 [FLINK-23183][connectors/rabbitmq] Fix ACKs for redelivered messages in RMQSource and add integration tests by Michal Ciesielczyk · 2 years, 10 months ago
  64. 654d6d0 [FLINK-23322][connectors/rabbitmq] Increase RMQSource handshake timeout tolerating network congestions by Fabian Paul · 2 years, 10 months ago
  65. 1c747da [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 10 months ago
  66. 8a1d042 [FLINK-22386][tests] Cache docker images by Mika · 2 years, 9 months ago
  67. 26f98b0 Revert "[FLINK-18783] Load Akka with separate classloader" by Piotr Nowojski · 2 years, 10 months ago
  68. 9a1f592 [FLINK-18783] Load Akka with separate classloader by Chesnay Schepler · 2 years, 10 months ago
  69. c0dc1fc [FLINK-23182][connectors/rabbitmq] Fix connection leak in RMQSource by Michal Ciesielczyk · 2 years, 10 months ago
  70. fe71aa0 [FLINK-21448] Add dependency for ChangelogStateBackend ITTests by Yangyang ZHANG · 2 years, 10 months ago
  71. 3513159 [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout to RabbitMQ source by Michal Ciesielczyk · 3 years ago
  72. c9417bd Update version to 1.14-SNAPSHOT by GuoWei Ma · 3 years ago
  73. 92e3066 [hotfix][docs] Correct rendering of maven modules by Seth Wiesman · 3 years, 2 months ago
  74. 7af0ba2 [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo by Seth Wiesman · 3 years, 3 months ago
  75. 1639f3f [FLINK-20651] Format code with Spotless/google-java-format by Rufus Refactor · 3 years, 4 months ago
  76. 6679f53 Update version to 1.13-SNAPSHOT by Dian Fu · 3 years, 5 months ago
  77. 123fc33 [FLINK-18363] Add user classloader to context in DeSerializationSchema by Dawid Wysakowicz · 3 years, 6 months ago
  78. 47a34a0 [FLINK-17502] [flink-connector-rabbitmq] RMQSource custom deserialization schema by Karim Mansour · 3 years, 7 months ago
  79. 4944471 [hotfix] Drop unnecessary PowerMockRunner from RMQSourceTest by Dawid Wysakowicz · 3 years, 7 months ago
  80. 1afa778 [FLINK-17529][connectors/rabbitmq] Upgrade com.rabbitmq:amqp-client to 5.9.0 by austin ce · 3 years, 9 months ago
  81. 9a975fb [FLINK-10195][connectors/rabbitmq] Allow setting QoS by austin ce · 3 years, 11 months ago
  82. 86934df [FLINK-18607][build] Give the maven module a human readable name by Niels Basjes · 3 years, 9 months ago
  83. d29e4e9 [FLINK-17376] Remove deprecated state access methods by Ghildiyal · 4 years ago
  84. 80611de Update version to 1.12-SNAPSHOT by Piotr Nowojski · 4 years ago
  85. f433f22 [FLINK-7267][connectors/rabbitmq] Allow overriding RMQSink connection by austin ce · 4 years ago
  86. 92fbae3 [FLINK-7267][connectors/rabbitmq] Allow overriding RMQSource connection by austin ce · 4 years ago
  87. a9d3264 [FLINK-17307] Add collector to deserialize in RMQ by Dawid Wysakowicz · 4 years ago
  88. 72c99a9 [FLINK-17204][connectors/rabbitmq] Make RMQ queue declaration consistent between source and sink by austin ce · 4 years ago
  89. d4a3ccc [FLINK-17306] Call open of SerializationSchema in RMQ sink by Dawid Wysakowicz · 4 years ago
  90. 7db8af8 [FLINK-17306] Call open of DeserializationSchema in RMQ by Dawid Wysakowicz · 4 years ago
  91. f97f44e Update version to 1.11-SNAPSHOT by Gary Yao · 4 years, 5 months ago
  92. f61c4c3 [FLINK-14562] Let RabbitMQ source close consumer and channel on close by Nicolas Deslandes · 4 years, 6 months ago
  93. 5741ea8 Update version to 1.10-SNAPSHOT by Kurt Young · 4 years, 10 months ago
  94. 1c568c3 Update version to 1.9-SNAPSHOT by Aljoscha Krettek · 5 years ago
  95. a77c4a3 Update version to 1.8-SNAPSHOT by Till Rohrmann · 5 years ago
  96. e46a8c1 Update version to 1.7-SNAPSHOT by Till Rohrmann · 6 years ago
  97. 29da14d [FLINK-8468][RabbitMQ] Improve RabbitMQ connector by gyao · 6 years ago
  98. 40410dc [FLINK-8468][RabbitMQ] Make RabbitMQ connector to take advantage of AMQP features (routing key, exchange and message properties) by Philippe Duveau · 6 years ago
  99. d1d9926 Update version to 1.6-SNAPSHOT by Till Rohrmann · 6 years ago
  100. 2d8b323 [hotfix] Remove outdated class OperatorStateHandles and replace it with OperatorSubtaskState by Stefan Richter · 6 years ago