export declare const serve: {
  (
    options: Consumer.ConsumerOptions
  ): <E, R>(
    app: MessageRouter.MessageRouter<E, R>
  ) => Layer.Layer<
    never,
    Error.ConnectionException,
    KafkaInstance.KafkaInstance | Exclude<R, ConsumerRecord.ConsumerRecord | Scope.Scope>
  >
  <E, R>(
    app: MessageRouter.MessageRouter<E, R>,
    options: Consumer.ConsumerOptions
  ): Layer.Layer<
    never,
    Error.ConnectionException,
    KafkaInstance.KafkaInstance | Exclude<R, ConsumerRecord.ConsumerRecord | Scope.Scope>
  >
}

export declare const serveEffect: {
  (
    options: Consumer.ConsumerOptions
  ): <E, R>(
    app: MessageRouter.MessageRouter<E, R>
  ) => Effect.Effect<
    void,
    Error.ConnectionException,
    Scope.Scope | KafkaInstance.KafkaInstance | Exclude<R, ConsumerRecord.ConsumerRecord>
  >
  <E, R>(
    app: MessageRouter.MessageRouter<E, R>,
    options: Consumer.ConsumerOptions
  ): Effect.Effect<
    void,
    Error.ConnectionException,
    Scope.Scope | KafkaInstance.KafkaInstance | Exclude<R, ConsumerRecord.ConsumerRecord>
  >
}

export declare const serveStream: (
  path: MessageRouter.Route.Path
) => Stream.Stream<ConsumerRecord.ConsumerRecord, never, Consumer>

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

export declare const make: (options: {
  readonly run: (app: MessageRouter.MessageRouter) => Effect.Effect<void>
  readonly runStream: (path: MessageRouter.Route.Path) => Stream.Stream<ConsumerRecord.ConsumerRecord>
}) => Consumer

export declare const makeConsumer: (
  options: Consumer.ConsumerOptions
) => Effect.Effect<Consumer, Error.ConnectionException, KafkaInstance.KafkaInstance | Scope.Scope>

export declare const layer: (
  options: Consumer.ConsumerOptions
) => Layer.Layer<Consumer, Error.ConnectionException, KafkaInstance.KafkaInstance>

export interface Consumer {
  readonly [TypeId]: TypeId
  readonly run: {
    <E, R>(
      app: MessageRouter.MessageRouter<E, R>
    ): Effect.Effect<void, never, Exclude<R, ConsumerRecord.ConsumerRecord>>
  }
  readonly runStream: {
    (path: MessageRouter.Route.Path): Stream.Stream<ConsumerRecord.ConsumerRecord>
  }
}

export declare const TypeId: typeof TypeId

export type TypeId = typeof TypeId

export interface ConsumerOptions extends KafkaJS.ConsumerConfig {}