@midwayjs/kafka

Index

Classes

• Configuration
• Framework
• KafkaAdminFactory
• KafkaProducerFactory

Functions

• KafkaConsumer

Interfaces

• Context
• IKafkaApplication
• IKafkaConsumer
• IKafkaConsumerInitOptions
• IMidwayConsumerConfig
• IMidwayKafkaAdminInitOptions
• IMidwayKafkaConfigurationOptions
• IMidwayKafkaProducerInitOptions

Type Aliases

• Application
• DefaultConfig
• IMidwayKafkaApplication
• IMidwayKafkaContext
• NextFunction

Variables

• KAFKA_DECORATOR_KEY

Type Aliases

Application

Application: IMidwayKafkaApplication

DefaultConfig

DefaultConfig: string | Kafka

IMidwayKafkaApplication

IMidwayKafkaApplication: IMidwayApplication<IMidwayKafkaContext> & IKafkaApplication

IMidwayKafkaContext

IMidwayKafkaContext: IMidwayContext<{ consumer: Consumer; message?: any; partition?: any; payload: EachMessagePayload | EachBatchPayload; topic?: any; commitOffsets?: any }>

NextFunction

NextFunction: BaseNextFunction

Variables

constKAFKA_DECORATOR_KEY

KAFKA_DECORATOR_KEY: rpc:kafka = 'rpc:kafka'