Flink Control
Submit Job
Dashboard
Load Config
System Ready
Job Configuration
Job Name
Parallelism
Checkpoint Interval (ms)
Sources
+ Add Source
Source #1
Remove
Bootstrap Servers
Topic
Group ID
Starting Offset
Earliest
Latest
Group Offsets (Committed)
Timestamp
Offset Timestamp (Unix ms)
Source Table Name (for SQL)
Data Schema (JSON Schema):
Optional. Used for validation.
Enable Watermark Generation
Process Time (Default)
Existing Timestamp Column
Timestamp Column Name
Authentication Protocol
None
SASL_PLAINTEXT
SASL_SSL
Data Format
String
JSON
Avro
SASL Mechanism
PLAIN
SCRAM-SHA-256
Username
Password
Target (Kafka)
Bootstrap Servers
Topic
Authentication Type:
None
SASL_PLAINTEXT
SASL_SSL
Data Format:
String
JSON
Avro
Target Schema (Optional/Required for Avro):
SASL Mechanism
PLAIN
SCRAM-SHA-256
Username
Password
Transformation Logic (SQL)
SQL Query
Use table names from source/target config. Default source table is 'source_table' or as defined above.
Result Table Name
Validate Configuration
Deploy Job
Running Jobs
Refresh
No jobs found. Submit a job to see it here.