跳到主要内容
版本:Next

@midwayjs/kafka

Index

Type Aliases

Application

DefaultConfig

DefaultConfig: string | Kafka

IMidwayKafkaApplication

IMidwayKafkaApplication: IMidwayApplication<IMidwayKafkaContext> & IKafkaApplication

IMidwayKafkaContext

IMidwayKafkaContext: IMidwayContext<{ message: any; partition: any; topic: any; commitOffsets: any }>

NextFunction

NextFunction: BaseNextFunction