rjbaucells commented on PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#issuecomment-2243290547
Hello,
What is the status of this PR?
Thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
vahmed-hamdy commented on PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#issuecomment-2223412688
@paulh86 Blocked on review from the community, will reach out on dev slack
channel for a reviewer
--
This is an automated message from the Apache Git Service.
To
paulh86 commented on PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#issuecomment-2205851900
Any updates?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
morazow commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1609538026
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/sink/RabbitMQSinkWriter.java:
##
@@ -0,0 +1,258 @@
+package
morazow commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1609531137
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/sink/RabbitMQSinkWriter.java:
##
@@ -0,0 +1,260 @@
+package
vahmed-hamdy commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1604736511
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/common/RabbitMQConnectionConfig.java:
##
@@ -0,0 +1,465 @@
+package
vahmed-hamdy commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1604735515
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/sink/RabbitMQSinkWriter.java:
##
@@ -0,0 +1,260 @@
+package
vahmed-hamdy commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1604725820
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/common/RabbitMQConnectionSetupException.java:
##
@@ -0,0 +1,13 @@
vahmed-hamdy commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1604717135
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/common/RabbitMQConnectionConfig.java:
##
@@ -0,0 +1,465 @@
+package
morazow commented on code in PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#discussion_r1601778225
##
flink-connector-rabbitmq/src/main/java/org/apache/flink/connector/rabbitmq/common/RabbitMQConnectionConfig.java:
##
@@ -0,0 +1,465 @@
+package
vahmed-hamdy commented on PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#issuecomment-2092561482
@MartijnVisser @zentol could you please review?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
vahmed-hamdy opened a new pull request, #29:
URL: https://github.com/apache/flink-connector-rabbitmq/pull/29
## Purpose of the change
Add SinkV2 implemetation for RabbitMQ.
## Verifying this change
Please make sure both new and modified tests in this PR follows
boring-cyborg[bot] commented on PR #29:
URL:
https://github.com/apache/flink-connector-rabbitmq/pull/29#issuecomment-2090628185
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This
13 matches
Mail list logo
