Web3j
Web3j source connector
Support Those Enginesâ
Spark
Flink
Seatunnel Zeta
Key Featuresâ
Descriptionâ
Source connector for web3j. It is used to read data from the blockchain, such as block information, transactions, smart contract events, etc. Currently, it supports reading block height data.
Source Optionsâ
Name | Type | Required | Default | Description |
---|---|---|---|---|
url | String | Yes | - | When using Infura as the service provider, the URL is used for communication with the Ethereum network. |
How to Create a Http Data Synchronization Jobsâ
env {
parallelism = 1
job.mode = "BATCH"
}
source {
Web3j {
url = "https://mainnet.infura.io/v3/xxxxx"
}
}
# Console printing of the read Http data
sink {
Console {
parallelism = 1
}
}
Then you will get the following data:
{"blockNumber":19525949,"timestamp":"2024-03-27T13:28:45.605Z"}
Changelogâ
- Add Web3j Source Connector