test-pipeline-input:
    source:
        elasticsearch:
            hosts: ["http://host1", "http://host2"]
            username: "test_user"
            password: "password"
    processor:
        - plugin1:
            str_array: ["abc", "x y z"]
            obj_array:
                - key: "key1"
                  value: "val1"
                - key: "key2"
                  value: "val 2"
    sink:
        - sink1:
            num_array: [0]
        - opensearch:
            hosts: ["https://os_host"]
            username: "test_user"
            password: "test"