error

export declare class ConnectionException {
  constructor(options: { readonly broker?: string; readonly message: string; readonly stack?: string })
}

export type KafkaError = ConnectionException