Usage

Create the service

@scripts/recovery.js

import {RecoveryService} from '@playtini/beta7';
import {redis} from '@services';
import {env} from '@utils';

(async () => {
  await redis.connect();

  const recoveryService = new RecoveryService({
    nodeID: env('NODE_ID'), // Уникальный для recovery-сервиса
    kafkaBrokers: env('KAFKA_BROKERS'), // Массив URL:PORT для подключения к Kafka
    schemaRegistry: env('SCHEMA_REGISTRY'), // URL для подключения к Schema Registry,
    restoreTopic: env('BASE_TOPIC_NAME'), // Topic который нужно прочитать и переиграть
  });

  const handleAction = (data) => { // Функция обработки каждого ивента
    console.warn(data) // payload => decoded message.value
  };

  await recoveryService.start(handleAction); // Начало работы скрипта
})();