Configuration

Reference

copysourcepekko.kafka.producer {
    discovery-method = ${?PEKKO_KAFKA_PRODUCER_DISCOVERY_METHOD}
    service-name = ${?PEKKO_KAFKA_PRODUCER_SERVICE_NAME}
    resolve-timeout = ${?PEKKO_KAFKA_PRODUCER_RESOLVE_TIMEOUT}
    parallelism = ${?PEKKO_KAFKA_PRODUCER_PARALLELISM}
    close-timeout = ${?PEKKO_KAFKA_PRODUCER_CLOSE_TIMEOUT}
    close-on-producer-stop = ${?PEKKO_KAFKA_PRODUCER_CLOSE_ON_PRODUCER_STOP}
    use-dispatcher = ${?PEKKO_KAFKA_PRODUCER_USE_DISPATCHER}
    eos-commit-interval = ${?PEKKO_KAFKA_PRODUCER_EOS_COMMIT_INTERVAL}
}

restore {
    from-when = ${?RESTORE_FROM_WHEN}
    override-topics = ${?RESTORE_OVERRIDE_TOPICS}
}

Scala API doc Restore

Explanation

• pekko.kafka.producer: See documentation
• pekko.kafka.producer.kafka-clients: See documentation
• restore:
  • from-when: An ISO-8601 time that specifies from when topics need to be restored. Note that the time used is based on the original Kafka timestamp and NOT the current time.
  • override-topics: A mapping of currently backed up topics to a new topic in the destination Kafka cluster