Zongwen Li
Zongwen Li
I can work for `Apache pulsar` source connector.
https://github.com/apache/incubator-seatunnel/issues/2299
This is a common feature, for example, kafka, HTTP, File, Pulsar, etc; My opinion is to conform to the habit of SQL; ```conf # conf file Source { schema {...
CC @Hisoka-X @CalvinKirs @ruanwenjun
Because [Testcontainers are tightly coupled with JUnit4](https://github.com/testcontainers/testcontainers-java/issues/970), we can't completely remove junit4, maybe we need a check style rule to banned the import of junit4 class.
Please check if `avatica-core-${version}.jar` is missing.
We can implement it based on [Debezium](https://debezium.io/) and [Netflix's DBLog parallel algorithm](https://netflixtechblog.com/dblog-a-generic-change-data-capture-framework-69351fb9099b)
> We can implement it based on [Debezium](https://debezium.io/) and [Netflix's DBLog parallel algorithm](https://netflixtechblog.com/dblog-a-generic-change-data-capture-framework-69351fb9099b) 1. Supports multi-table and sharding (Easy Configuration) 2. Supports parallel reading of historical data (Fast synchronization, billions...
You can add a method using catalog. ```java // org.apache.seatunnel.api.table.catalog.Catalog public interface Catalog { void createTable(TablePath tablePath, CatalogTable table, boolean ignoreIfExists); } ``` CatalogTable can represent partitioning keys, primary keys,...
@IeohMingChan Yes, it is supported by regular expressions