- Source
- Kafka
- RocketMQ
- Redis
- List
- LPop
- RPop
- Pub/Sub
- Subscribe(default using PSubscribe)
- List
- Pulsar
- RabbitMQ
- Prometheus metrics exporter(etc. get /metrics)
- Sink
- ClickHouse
- Console
- HTTP
- POST
- GET (temporary not support)
- Kafka
- Redis
- K/V
- Set
- Hash
- HSet
- List
- LPush
- RPush
- Set
- SAdd
- Pub/Sub
- Publish
- K/V
- PostgresSQL
- Elasticsearch 7/8
- LocalFile
- text(like txt)
- csv
- Pulsar
- RabbitMQ
- RocketMQ
- MySQL
- Oracle
- transform
- DataType Cast
- K-V Expand
- K-V Filter
- K-V Strict Mode
- Json Mode
- JsonPath Mode
- config center
- Local
- Apollo
- Redis
- Nacos
- Zookeeper
- HTTP-Get
- Prometheus
- pprof