Support Apache RocketMQ Version Support These Engines Key Features Description Source Options start.mode.offsets Task Example Simple: Specified format consumption Simple: S...
Introduction Support Those Engines API Event Data API Event Listener API Event Collect API Configuration Listener Zeta Engine Flink Engine Spark Engine Introduction The...
_(value) Arguments Returns Example _.chain(value) Since Arguments Returns Example _.tap(value, interceptor) Since Arguments Returns Example _.thru(value, intercept...
Spark Streaming Spark Streaming Structured Streaming reads are based on Hudi’s Incremental Query feature, therefore streaming read can return data for which commits and base fil...
Support Those Engines Description Key Features Sink Options Task Example Amazon SQS sink connector Support Those Engines Spark Flink SeaTunnel Zeta Description Writ...
Kyuubi Server Metrics Configurations Metrics Kyuubi Server Metrics Kyuubi has a configurable metrics system based on the Dropwizard Metrics Library . This allows users to repo...