Web3j

Web3j 源连接器

支持这些引擎

Spark
Flink
Seatunnel Zeta

关键特性

• 批
• 流
• 精确一次
• 列投影
• 并行性
• 支持用户自定义split

描述

Web3j 的源连接器。用于从区块链读取数据，例如区块信息、交易、智能合约事件等。目前支持读取区块高度数据。

源选项

参数名	类型	必须	默认值	描述
url	String	是	-	使用 Infura 作为服务提供商时，URL 用于与以太坊网络通信。

如何创建 Http 数据同步作业

env {
  parallelism = 1
  job.mode = "BATCH"
}

source {
  Web3j {
    url = "https://mainnet.infura.io/v3/xxxxx"
  }
}

# 控制台打印读取的 Http 数据
sink {
  Console {
    parallelism = 1
  }
}

然后您将获得以下数据：

{"blockNumber":19525949,"timestamp":"2024-03-27T13:28:45.605Z"}

变更日志

Change Log

Change	Commit	Version
[improve] update Web3j connector config option (#9005)	https://github.com/apache/seatunnel/commit/9204f289d8	2.3.10
[Feature][Connector-V2] Add web3j source connector (#6598)	https://github.com/apache/seatunnel/commit/b7002bfaf4	2.3.6