The topic where all messages which could not be processed successfully are sent The time duration of the window in milliseconds Add SerDe class name for a pattern in -custom-serde-inputs (supported for java fun only) The topic pattern to consume from list of topics under a namespace that match the pattern. This service URL must be added manually when the Pulsar Function runs locally. By default, it it set to the service URL of the Apache BookKeeper. The time duration after which the window slides The number of messages after which the window slides The builtin schema type or custom schema class name to be used for messages output by the function It also supports URL path from which worker can download the package. Path to the main Go executable binary for the function (if the function is written in Go). Path to the main Python file/Python Wheel file for the function (if the function is written in Python). The processing guarantees (aka delivery semantics) applied to the function. the number of instances of the function to run The SerDe class to be used for messages output by the function The function's output topic (If none is specified, no output is written) Path to the jar file for the function (if the function is written in Java). The topic to which the function's logs are produced The function's input topic or topics (multiple topics can be specified as a comma-separated list) The path to a YAML config file specifying the function's configuration The map of input topics to Schema class names (as a JSON string)Ĭlient authentication plugin using which function-process can connect to broker The map of input topics to SerDe class names (as a JSON string) Pulsar source subscription name if user wants a specific subscription-name for input-topic consumer Whether or not the framework will automatically acknowledge messages The disk in bytes that need to be allocated per function instance(applicable only to docker runtime) The ram in bytes that need to be allocated per function instance(applicable only to process/docker runtime) The cpu in cores that need to be allocated per function instance(applicable only to docker runtime)
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |