39.5. 端点选项

Flink 端点使用 URI 语法进行配置：

flink:endpointType

flink:endpointType

Copy to Clipboard

Toggle word wrap

使用以下 路径和 查询参数 ：

Expand

Name	描述	默认值	类型
endpointType (producer)	端点所需的类型(dataset、datastream)。 Enum 值： Dataset datastream		EndpointType

Name

描述

默认值

类型

endpointType (producer)

端点 所需的 类型(dataset、datastream)。

Enum 值：

EndpointType

Expand

Name	描述	默认值	类型
collect (producer)	指明是否应收集或计算结果。	true	布尔值
dataset ( producer)	到计算的数据集。		DataSet
dataSetCallback (producer)	对 DataSet 执行操作的功能。		DataSetCallback
datastream ( producer)	到计算的数据流。		DataStream
dataStreamCallback (producer)	对 DataStream 执行操作的功能。		DataStreamCallback
lazyStartProducer (producer (advanced))	生成者是否应懒惰启动（在第一个消息中）。通过懒惰启动，您可以使用此选项来允许 CamelContext 和路由在生成者启动期间启动，并导致路由启动失败。通过懒惰启动，启动失败可以在路由信息时通过 Camel 的路由错误处理程序进行处理。请注意，在处理第一个消息时，创建并启动生成者可能需要稍等时间，并延长处理的总处理时间。	false	布尔值

返回顶部