Comments (4)
Hi Team, I am working on this. I am implementing the source using AbstractSingleSplitSource. Can anyone confirm if I am doing the right things.
Hi @asapekia , welcome for contribute SeaTunnel! I suggest you refer to the implementation of kafka or rabbitmq, because the message queue involves multi-split and multi-parallel processing, and AbstractSingleSplitSource only provides a single parallel source.
from seatunnel.
Hi Team, I am working on this. I am implementing the source using AbstractSingleSplitSource. Can anyone confirm if I am doing the right things.
from seatunnel.
This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.
from seatunnel.
closed by #7251
from seatunnel.
Related Issues (20)
- Job turned from state RUNNING to FAILED , but job status is still RUNNING.
- Failed to authenticate connection com.hazelcast.client.AuthenticationException
- SeaTunnel community meeting Topic collect HOT 7
- [Bug] [transfor-v2] SQL transform plugin reports error when parsing fields starting with numbers HOT 2
- [Bug] [Module Name] flink使用start_mode = "timestamp"无效
- [Improvement] [Seatunnel-web] Add support to provide reason for job failure: UI change HOT 1
- [Feature][Zeta] add RestApi to update node tag HOT 2
- [Feature][Core] Added rest-api for batch start and stop HOT 1
- [Feature][Core]Added support for batch start and stop client commands HOT 1
- Hazelcast 5.5 CP Subsystem Changes - Impact on Project HOT 1
- [Bug] [Zeta] Unsupported MySQL version: 8.2.0
- [Bug] [Core]In Spark multi-table synchronization, there is inconsistent behavior compared to the Zeta engine.
- [Improvement] [Seatunnel-web] Add API to get job execution status. HOT 2
- [Bug] [Metric] When I add the transform operator the metrics are not correct HOT 1
- [Bug] [MONGO-CDC] Exception in org.apache.seatunnel.engine.server.task.SourceSeaTunnelTask
- [Bug] [cup] if task starting,cpu will 100%
- [Feature][Engine] Support Seatunnel on Yarn
- [Improvement] [Seatunnel-web] Add API to get and update job definition. HOT 2
- [Feature][Transform] Add embedding transform
- [Bug] [connector-v2] Dependency Conflict HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from seatunnel.