import { type CallbackWithPromise } from '../../apis/callbacks.ts';
import { type Message } from '../../protocol/records.ts';
import { kTransaction, kTransactionAddOffsets, kTransactionAddPartitions, kTransactionCancel, kTransactionCommitOffset, kTransactionEnd, kTransactionFindCoordinator } from '../../symbols.ts';
import { Base } from '../base/base.ts';
import { ProducerStream } from './producer-stream.ts';
import { Transaction } from './transaction.ts';
import { type ProduceOptions, type ProduceResult, type ProducerInfo, type ProducerOptions, type ProducerStreamOptions, type SendOptions } from './types.ts';
export declare function noopSerializer(data?: Buffer): Buffer | undefined;
export declare class Producer<Key = Buffer, Value = Buffer, HeaderKey = Buffer, HeaderValue = Buffer> extends Base<ProducerOptions<Key, Value, HeaderKey, HeaderValue>> {
    #private;
    constructor(options: ProducerOptions<Key, Value, HeaderKey, HeaderValue>);
    get producerId(): bigint | undefined;
    get producerEpoch(): number | undefined;
    get transaction(): Transaction<Key, Value, HeaderKey, HeaderValue> | undefined;
    get coordinatorId(): number;
    get streamsCount(): number;
    close(force: boolean | CallbackWithPromise<void>, callback?: CallbackWithPromise<void>): void;
    close(force?: boolean): Promise<void>;
    initIdempotentProducer(options: ProduceOptions<Key, Value, HeaderKey, HeaderValue>, callback: CallbackWithPromise<ProducerInfo>): void;
    initIdempotentProducer(options: ProduceOptions<Key, Value, HeaderKey, HeaderValue>): Promise<ProducerInfo>;
    send(options: SendOptions<Key, Value, HeaderKey, HeaderValue> & {
        [kTransaction]?: number;
    }, callback: CallbackWithPromise<ProduceResult>): void;
    send(options: SendOptions<Key, Value, HeaderKey, HeaderValue> & {
        [kTransaction]?: number;
    }): Promise<ProduceResult>;
    asStream(options?: ProducerStreamOptions<Key, Value, HeaderKey, HeaderValue>): ProducerStream<Key, Value, HeaderKey, HeaderValue>;
    beginTransaction(options: ProduceOptions<Key, Value, HeaderKey, HeaderValue>, callback: CallbackWithPromise<Transaction<Key, Value, HeaderKey, HeaderValue>>): void;
    beginTransaction(options?: ProduceOptions<Key, Value, HeaderKey, HeaderValue>): Promise<Transaction<Key, Value, HeaderKey, HeaderValue>>;
    [kTransactionFindCoordinator](callback: CallbackWithPromise<void>): void;
    [kTransactionAddPartitions](transactionId: number, topicsPartitions: Map<string, Set<number>>, callback: CallbackWithPromise<void>): void;
    [kTransactionAddOffsets](transactionId: number, groupId: string, callback: CallbackWithPromise<void>): void;
    [kTransactionCommitOffset]<MessageKey = Buffer, MessageValue = Buffer, MessageHeaderKey = Buffer, MessageHeaderValue = Buffer>(transactionId: number, message: Message<MessageKey, MessageValue, MessageHeaderKey, MessageHeaderValue>, callback: CallbackWithPromise<void>): void;
    [kTransactionEnd](transactionId: number, commit: boolean, callback: CallbackWithPromise<void>): void;
    [kTransactionCancel](transactionId: number, callback: CallbackWithPromise<void>): void;
}