HotMeshWorker: {
    callback: ((payload: StreamData) => Promise<StreamDataResponse>);
    reclaimCount?: number;
    reclaimDelay?: number;
    redis?: RedisConfig;
    store?: RedisClient;
    stream?: RedisClient;
    sub?: RedisClient;
    topic: string;
}