base-config.conf

kafka {
  consumer.broker-servers = "localhost:9092"
  producer {
    broker-servers = "localhost:9092"
    max-request-size = 1572864
    batch.size = 98304
    linger.ms = 10
  }
}

job {
  env = "local"
  bb = "lern"
  enable.distributed.checkpointing = false
  statebackend {
    blob {
      storage {
        account = "blob.storage.account"
        container = "telemetry-container"
        checkpointing.dir = "flink-jobs"
      }
    }
    base.url = "wasbs://"${job.statebackend.blob.storage.container}"@"${job.statebackend.blob.storage.account}"/"${job.statebackend.blob.storage.checkpointing.dir}
  }
}

task {
  checkpointing.compressed = true
  checkpointing.interval = 60000
  checkpointing.pause.between.seconds = 30000
  restart-strategy.attempts = 3
  restart-strategy.delay = 30000 # in milli-seconds
  parallelism = 1
  consumer.parallelism = 1
}

redisdb.connection.timeout = 30000

redis {
  host = localhost
  port = 6379
}

redis-meta {
  host = localhost
  port = 6379
}

lms-cassandra {
  host = "localhost"
  port = "9042"
  isMultiDCEnabled = false
}

ml-cassandra {
  host = "localhost"
  port = "9042"
  isMultiDCEnabled = false
}