export declare const make: (payload: {
  readonly topic: string
  readonly partition: number
  readonly highWatermark: string
  readonly key: Buffer | null
  readonly value: Buffer | null
  readonly timestamp: string
  readonly attributes: number
  readonly offset: string
  readonly headers?: ConsumerRecord.Headers
  readonly size?: number
  readonly heartbeat: () => Effect.Effect<void>
  readonly commit: () => Effect.Effect<void>
}) => ConsumerRecord

export declare const ConsumerRecord: Context.Tag<ConsumerRecord, ConsumerRecord>

export interface ConsumerRecord {
  readonly [TypeId]: TypeId
  readonly topic: string
  readonly partition: number
  readonly highWatermark: string
  readonly key: Buffer | null
  readonly value: Buffer | null
  readonly timestamp: string
  readonly attributes: number
  readonly offset: string
  readonly headers?: ConsumerRecord.Headers
  readonly size?: number
  // readonly resolveOffset: (offset: string) => void;
  readonly heartbeat: () => Effect.Effect<void>
  // readonly pause: () => () => void;
  readonly commit: () => Effect.Effect<void>
}

export declare const TypeId: typeof TypeId

export type TypeId = typeof TypeId

export interface Headers extends KafkaJS.IHeaders {}