You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/12/13 09:40:54 UTC
[flink-connector-rabbitmq] branch main updated (b299fa1 -> 70409b8)
This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-rabbitmq.git
from b299fa1 [hotfix][ci] Fail on architecture tests store update
new 75ee64e [FLINK-4676] [connectors] Merge batch and streaming connectors into common Maven module.
new f5a2f47 [FLINK-5163] Port the MessageAcknowledgingSourceBase to the new state abstractions.
new f8802db [build system] Update version to 1.3-SNAPSHOT
new e10c5b0 [FLINK-5639] [rabbitmq connector] Add a note about MPL 1.1 license of Maven dependency
new 1ca9747 [FLINK-5716] [streaming] Make StreamSourceContexts aware of source idleness
new 29ec21e [FLINK-5824] Fix String/byte conversions without explicit encoding
new 107ef6c Update Flink version to 1.4-SNAPSHOT
new c74124d [FLINK-6414] [build] Use scala.binary.version in place of change-scala-version.sh
new 54add4f [FLINK-6711] Activate strict checkstyle for flink-connector-rabbitmq
new 0328646 [FLINK-7347] Keep IDs for checkpoint in a set in MessageQueue Source
new b6c19cc [FLINK-7552] Extend SinkFunction interface with SinkContext
new f2dfed0 [FLINK-7654] [rabbitmq] Update RabbitMQ Java client version to 4.2.0
new 49a3dd3 [FLINK-7972] [core] Move SerializationSchema to 'flink-core'
new 71cf389 Update version to 1.5-SNAPSHOT
new 6108645 [hotfix] Fix many many typos
new 2d8b323 [hotfix] Remove outdated class OperatorStateHandles and replace it with OperatorSubtaskState
new d1d9926 Update version to 1.6-SNAPSHOT
new 40410dc [FLINK-8468][RabbitMQ] Make RabbitMQ connector to take advantage of AMQP features (routing key, exchange and message properties)
new 29da14d [FLINK-8468][RabbitMQ] Improve RabbitMQ connector
new e46a8c1 Update version to 1.7-SNAPSHOT
new a77c4a3 Update version to 1.8-SNAPSHOT
new 1c568c3 Update version to 1.9-SNAPSHOT
new 5741ea8 Update version to 1.10-SNAPSHOT
new f61c4c3 [FLINK-14562] Let RabbitMQ source close consumer and channel on close
new f97f44e Update version to 1.11-SNAPSHOT
new 7db8af8 [FLINK-17306] Call open of DeserializationSchema in RMQ
new d4a3ccc [FLINK-17306] Call open of SerializationSchema in RMQ sink
new 72c99a9 [FLINK-17204][connectors/rabbitmq] Make RMQ queue declaration consistent between source and sink
new a9d3264 [FLINK-17307] Add collector to deserialize in RMQ
new 92fbae3 [FLINK-7267][connectors/rabbitmq] Allow overriding RMQSource connection
new f433f22 [FLINK-7267][connectors/rabbitmq] Allow overriding RMQSink connection
new 80611de Update version to 1.12-SNAPSHOT
new d29e4e9 [FLINK-17376] Remove deprecated state access methods
new 86934df [FLINK-18607][build] Give the maven module a human readable name
new 9a975fb [FLINK-10195][connectors/rabbitmq] Allow setting QoS
new 1afa778 [FLINK-17529][connectors/rabbitmq] Upgrade com.rabbitmq:amqp-client to 5.9.0
new 4944471 [hotfix] Drop unnecessary PowerMockRunner from RMQSourceTest
new 47a34a0 [FLINK-17502] [flink-connector-rabbitmq] RMQSource custom deserialization schema
new 123fc33 [FLINK-18363] Add user classloader to context in DeSerializationSchema
new 6679f53 Update version to 1.13-SNAPSHOT
new 1639f3f [FLINK-20651] Format code with Spotless/google-java-format
new 7af0ba2 [FLINK-21193][docs] Migrate Flink docs from Jekyll to Hugo
new 92e3066 [hotfix][docs] Correct rendering of maven modules
new c9417bd Update version to 1.14-SNAPSHOT
new 3513159 [FLINK-22698][connectors/rabbitmq] Add deliveryTimeout to RabbitMQ source
new fe71aa0 [FLINK-21448] Add dependency for ChangelogStateBackend ITTests
new c0dc1fc [FLINK-23182][connectors/rabbitmq] Fix connection leak in RMQSource
new 9a1f592 [FLINK-18783] Load Akka with separate classloader
new 26f98b0 Revert "[FLINK-18783] Load Akka with separate classloader"
new 8a1d042 [FLINK-22386][tests] Cache docker images
new 1c747da [FLINK-18783] Load Akka with separate classloader
new 654d6d0 [FLINK-23322][connectors/rabbitmq] Increase RMQSource handshake timeout tolerating network congestions
new e645137 [FLINK-23183][connectors/rabbitmq] Fix ACKs for redelivered messages in RMQSource and add integration tests
new 70966aa [hotfix][test/testcontainers] Use Testcontainer BOM to manage versions in the project
new 2cfebf7 Update version to 1.15-SNAPSHOT
new d2d9dfb [FLINK-23859] Fix typos
new 09d9579 [FLINK-23607][state/changelog] Make Changelog Backend a transitive dependency
new c236a9d [FLINK-23651][python] Support RabbitMQ in PyFlink
new 162eae3 [FLINK-24018][build] Remove Scala dependencies from Java APIs
new 663476c [FLINK-24806][connectors/rabbitmq] Fix container startup in RMQSourceITCase
new 798904a [FLINK-24816][rabbitmq] Bump amqp-client to v5.13.1
new 2d9c644 [FLINK-23696][connectors/rabbitmq] Fix RMQSourceTest.testRedeliveredSessionIDsAck test
new 5efb318 [FLINK-25039][build] Disable shading of test jar by default
new 0f5bca9 [Hotfix] Fix typos.
new 1ec28f4 [hotfix][connectors] Every connector now shades the flink-connector-base in its uber jar
new fb666d1 [FLINK-25744] Support native savepoints
new 8b4fdf0 [FLINK-25129][docs] Restructure project configuation pages
new 3b57c34 [FLINK-25892][rabbitmq][test] add ArchUnit tests for test code
new 5057517 [hotfix] Fix JUnit 5 mini cluster arch unit rules
new b094ff9 [FLINK-26294][test] Using fixed description for ArchUnit ITCaseRules
new 94d3e2d Update version to 1.16-SNAPSHOT
new 092e9e9 [FLINK-26578][docs-zh] Translate new Project Configuration section to Chinese. This closes #19100
new d27d589 [FLINK-26616][tests] Remove deadlines from CommonTestUtils
new 7b2b79a [FLINK-24721][build] Remove unnecessary relativePath to parent
new c0c65d4 [FLINK-28140][python][docs] Improve the documentation connector pages and metrics pages
new c688609 [FLINK-28904][python][docs] Add missing connector/format documentation
new 6272125 [FLINK-28676] Update copyright year to 2014-2022 in NOTICE files
new 6ed8fdb [FLINK-25868][build] Disable japicmp in packaging/e2e modules
new a80c0f4 [FLINK-30279][Connector/RabbitMQ] Move existing RabbitMQ connector code from Flink repo to dedicated RabbitMQ repo
new 70409b8 [FLINK-30279][Archunit] Add Archunit rule violations
The 80 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitmodules | 4 +
.../docs/connectors/datastream/rabbitmq.md | 230 ++++++
.../content/docs/connectors/datastream/rabbitmq.md | 254 ++++++
flink-connector-rabbitmq/README.md | 11 +
.../22086d11-ddf8-434e-96c5-fa40a17ab23e | 0
.../307488e0-e1a9-4cf2-b553-927354a43ccb | 1 +
.../5a2e5113-39c5-4eb6-909f-112ea364a2e4 | 0
.../621a723f-8a32-41f8-b2a5-9af8e4826fe7 | 0
.../812e4273-9fd1-4c6b-8c29-26820f00de12 | 0
.../8c639c33-2f7a-4162-8b5d-de800dd0d530 | 0
.../c24c7b04-08c8-464c-b627-44e9ce4ee776 | 0
.../d421b256-1055-4fec-a856-2a40f96d22f8 | 0
.../archunit-violations/stored.rules | 10 +
flink-connector-rabbitmq/pom.xml | 94 +++
.../connectors/rabbitmq/QueueingConsumer.java | 159 ++++
.../rabbitmq/RMQDeserializationSchema.java | 104 +++
.../rabbitmq/RMQDeserializationSchemaWrapper.java | 64 ++
.../streaming/connectors/rabbitmq/RMQSink.java | 269 +++++++
.../connectors/rabbitmq/RMQSinkPublishOptions.java | 80 ++
.../streaming/connectors/rabbitmq/RMQSource.java | 442 +++++++++++
.../rabbitmq/SerializableReturnListener.java | 26 +
.../flink/streaming/connectors/rabbitmq/Util.java | 36 +
.../rabbitmq/common/RMQConnectionConfig.java | 608 +++++++++++++++
.../ProductionCodeArchitectureTest.java | 41 +
.../architecture/TestCodeArchitectureTest.java | 40 +
.../streaming/connectors/rabbitmq/RMQSinkTest.java | 363 +++++++++
.../connectors/rabbitmq/RMQSourceITCase.java | 235 ++++++
.../connectors/rabbitmq/RMQSourceTest.java | 855 +++++++++++++++++++++
.../rabbitmq/common/RMQConnectionConfigTest.java | 174 +++++
.../src/test/resources/archunit.properties | 31 +
.../src/test/resources/log4j2-test.properties | 18 +-
flink-sql-connector-rabbitmq/pom.xml | 82 ++
.../src/main/resources/META-INF/NOTICE | 9 +
pom.xml | 371 +++++++++
tools/releasing/shared | 1 +
35 files changed, 4604 insertions(+), 8 deletions(-)
create mode 100644 .gitmodules
create mode 100644 docs/content.zh/docs/connectors/datastream/rabbitmq.md
create mode 100644 docs/content/docs/connectors/datastream/rabbitmq.md
create mode 100644 flink-connector-rabbitmq/README.md
create mode 100644 flink-connector-rabbitmq/archunit-violations/22086d11-ddf8-434e-96c5-fa40a17ab23e
create mode 100644 flink-connector-rabbitmq/archunit-violations/307488e0-e1a9-4cf2-b553-927354a43ccb
create mode 100644 flink-connector-rabbitmq/archunit-violations/5a2e5113-39c5-4eb6-909f-112ea364a2e4
create mode 100644 flink-connector-rabbitmq/archunit-violations/621a723f-8a32-41f8-b2a5-9af8e4826fe7
create mode 100644 flink-connector-rabbitmq/archunit-violations/812e4273-9fd1-4c6b-8c29-26820f00de12
create mode 100644 flink-connector-rabbitmq/archunit-violations/8c639c33-2f7a-4162-8b5d-de800dd0d530
create mode 100644 flink-connector-rabbitmq/archunit-violations/c24c7b04-08c8-464c-b627-44e9ce4ee776
create mode 100644 flink-connector-rabbitmq/archunit-violations/d421b256-1055-4fec-a856-2a40f96d22f8
create mode 100644 flink-connector-rabbitmq/archunit-violations/stored.rules
create mode 100644 flink-connector-rabbitmq/pom.xml
create mode 100644 flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/QueueingConsumer.java
create mode 100644 flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQDeserializationSchema.java
create mode 100644 flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQDeserializationSchemaWrapper.java
create mode 100644 flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java
create mode 100644 flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkPublishOptions.java
create mode 100644 flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java
create mode 100644 flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/SerializableReturnListener.java
create mode 100644 flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/Util.java
create mode 100644 flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java
create mode 100644 flink-connector-rabbitmq/src/test/java/org/apache/flink/architecture/ProductionCodeArchitectureTest.java
create mode 100644 flink-connector-rabbitmq/src/test/java/org/apache/flink/architecture/TestCodeArchitectureTest.java
create mode 100644 flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSinkTest.java
create mode 100644 flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java
create mode 100644 flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceTest.java
create mode 100644 flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfigTest.java
create mode 100644 flink-connector-rabbitmq/src/test/resources/archunit.properties
copy docs/config.yaml => flink-connector-rabbitmq/src/test/resources/log4j2-test.properties (70%)
create mode 100644 flink-sql-connector-rabbitmq/pom.xml
create mode 100644 flink-sql-connector-rabbitmq/src/main/resources/META-INF/NOTICE
create mode 100644 pom.xml
create mode 160000 tools/releasing/shared