Context

Hierarchy

• IMidwayKafkaContext
  • Context

Index

Properties

• consumer
• logger
• message
• partition
• payload
• requestContext
• startTime
• topic
• traceId

Methods

• commitOffsets
• getApp
• getAttr
• getLogger
• setAttr

Properties

consumer

consumer: Consumer

Inherited from IMidwayKafkaContext.consumer

logger

logger: ILogger

Inherited from IMidwayKafkaContext.logger

optionalmessage

message?: any

Inherited from IMidwayKafkaContext.message

@deprecated

please use ctx.payload instead

optionalpartition

partition?: any

Inherited from IMidwayKafkaContext.partition

@deprecated

please use ctx.payload instead

payload

payload: EachMessagePayload | EachBatchPayload

Inherited from IMidwayKafkaContext.payload

requestContext

requestContext: IMidwayContainer

Inherited from IMidwayKafkaContext.requestContext

Custom properties.

startTime

startTime: number

Inherited from IMidwayKafkaContext.startTime

optionaltopic

topic?: any

Inherited from IMidwayKafkaContext.topic

@deprecated

please use ctx.payload instead

optionaltraceId

traceId?: string

Inherited from IMidwayKafkaContext.traceId

Methods

optionalcommitOffsets

• commitOffsets(data: any): void

• Inherited from IMidwayKafkaContext.commitOffsets

  @deprecated

  please use ctx.consumer.commitOffsets instead

getApp

• getApp(): IMidwayBaseApplication<Context>

• Inherited from IMidwayKafkaContext.getApp

  Get current related application instance.

getAttr

• getAttr<T>(key: string): T

• Inherited from IMidwayKafkaContext.getAttr

  Get value from app attribute map

  ---

  Type parameters

  • T

getLogger

• getLogger(name?: string): ILogger

• Inherited from IMidwayKafkaContext.getLogger

setAttr

• setAttr(key: string, value: any): any

• Inherited from IMidwayKafkaContext.setAttr

  Set value to app attribute map