wuchunfu commented on PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#issuecomment-2712268113
@Hisoka-X @hailin0 PTAL, thanks.
--
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 spe
Hisoka-X commented on code in PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#discussion_r1982925091
##
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/resources/rocketmq-source_text_tag_to_console.conf:
##
@@ -0,0 +1,95 @@
+#
+# Licensed to
wuchunfu commented on PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#issuecomment-2702661488
@Hisoka-X @hailin0 PTAL, thanks
--
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 spec
Hisoka-X commented on code in PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#discussion_r1976838765
##
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/resources/rocketmq-source_text_error_tag_to_console.conf:
##
@@ -0,0 +1,84 @@
+#
+# Licen
wuchunfu commented on PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#issuecomment-2689400733
@Hisoka-X PATL, thanks.
--
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 com
wuchunfu commented on code in PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#discussion_r1974525703
##
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/java/org/apache/seatunnel/e2e/connector/rocketmq/RocketMqIT.java:
##
@@ -204,6 +204,22 @@
Hisoka-X commented on code in PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#discussion_r1971159655
##
seatunnel-e2e/seatunnel-connector-v2-e2e/connector-rocketmq-e2e/src/test/resources/rocketmq-source_text_tag_to_console.conf:
##
@@ -0,0 +1,92 @@
+#
+# Licensed to
wuchunfu commented on PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#issuecomment-2684249495
@Hisoka-X PATL, thanks.
--
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 com
wuchunfu commented on code in PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#discussion_r1970838018
##
docs/en/connector-v2/source/RocketMQ.md:
##
@@ -218,3 +219,62 @@ sink {
}
```
+### Specified timestamp Simple:
+
+> This is to specify a time to consume, and
Hisoka-X commented on code in PR #8825:
URL: https://github.com/apache/seatunnel/pull/8825#discussion_r1970828673
##
docs/en/connector-v2/source/RocketMQ.md:
##
@@ -218,3 +219,62 @@ sink {
}
```
+### Specified timestamp Simple:
+
+> This is to specify a time to consume, and
wuchunfu opened a new pull request, #8825:
URL: https://github.com/apache/seatunnel/pull/8825
### Purpose of this pull request
RocketMQ Source add message tag config
### Does this PR introduce _any_ user-facing change?
### How was this patch tested
11 matches
Mail list logo
