config/development.yaml [1:22]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
log_type: zap

logging:
  level: debug

state_update_interval: 10s
worker_idle_interval: 1s
state_connect_url: "storagetapper:storagetapper@localhost"

pipe:
    kafka:
        addresses:
            - "localhost:9091"
            - "localhost:9092"
            - "localhost:9093"
    hadoop:
        user: hadoop
        addresses:
            - "localhost:9000"
        base_dir: "/user/hadoop/tmp/hdfs_pipe_test"
    s3:
        region: "us-east-1"
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



config/test.yaml [1:22]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
log_type: zap

logging:
  level: debug

state_update_interval: 10s
worker_idle_interval: 1s
state_connect_url: "storagetapper:storagetapper@localhost"

pipe:
  kafka:
    addresses:
      - "localhost:9091"
      - "localhost:9092"
      - "localhost:9093"
  hadoop:
    user: hadoop
    addresses:
      - "localhost:9000"
    base_dir: "/user/hadoop/tmp/hdfs_pipe_test"
  s3:
    region: "us-east-1"
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



