import { SchemaRegistry } from '@kafkajs/confluent-schema-registry';
import { RawAvroSchema } from '@kafkajs/confluent-schema-registry/dist/@types';
export declare class DomainSchema<T> {
    readonly schemaValue: string;
    private readonly schema;
    private registry;
    private _registryId;
    constructor(schema?: string | Record<string, any>, disableSchemaRegistry?: Registry | boolean | null);
    encode(value: T): Promise<Buffer<ArrayBufferLike>>;
    decode(value: Buffer): Promise<T>;
    get isEnabled(): boolean;
    get isSchemaRegistryEnabled(): boolean;
    get registryId(): string | number;
}
export declare class Registry {
    private static self;
    private readonly url;
    private readonly overrides;
    schemaRegistry: SchemaRegistry;
    private alicloudSchemaRegistry;
    private glueSchemaRegistry;
    constructor(url: string, overrides?: any);
    static init(url: string, overrides?: any): Registry;
    static term(): void;
    clone(): Registry;
    register(schema: string | RawAvroSchema): Promise<string | number>;
    encode(id: number | string, payload: any): Promise<Buffer>;
    decode(payload: Buffer): Promise<any>;
    static get instance(): Registry;
    static get isEnabled(): boolean;
}