config.yaml

# Copyright 2024 Function Stream Org.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

# FunctionStream Configuration File
# This configuration file defines the settings for the string processing function example.

pulsar:
  serviceUrl: "pulsar://127.0.0.1:6650"  # Required: URL of the Pulsar broker
  authPlugin: ""  # Optional: Authentication plugin class name
  authParams: ""  # Optional: Authentication parameters

module: "string"  # Required: Name of the module to use for processing

# Optional: List of source topics to consume from
# Note: Either sources or requestSource must be specified
sources:
  - pulsar:  # SourceSpec structure with pulsar configuration
      topic: "topic-a"  # Topic name for regular message consumption

# Optional: request source
requestSource:
  pulsar:  # SourceSpec structure with pulsar configuration
    topic: "string-topic"  # Topic name for request messages

# Required: Name of the subscription for the consumer
subscriptionName: "test-sub"

# Optional: Output sink configuration
sink:
  pulsar:  # SinkSpec structure with pulsar configuration
    topic: "output"  # Topic name for output messages

# Optional: Additional configuration parameters
config:
  test: "Hello from config"  # Example configuration value
  test2: "Another config value"  # Another example configuration value