ConsumerRecover prevent consumer from panic.

ConsumerUow wrap handler into a unit of work (transaction).

Logging logging errors.

NewConsumerServer create server from Consumer directly.

NewProducer create a *SendWrap with middleware ability.

NewTransformer wrap handle by transform event to T.

Config_KafkaValidationError is the validation error returned by Config_Kafka.Validate if the designated constraints aren't met.

Config_PulsarValidationError is the validation error returned by Config_Pulsar.Validate if the designated constraints aren't met.

ConfigValidationError is the validation error returned by Config.Validate if the designated constraints aren't met.

ConsumerFactoryServer resolve LazyConsumer from factory, then wrap as kratos server.

Config_KafkaMultiError is an error wrapping multiple validation errors returned by Config_Kafka.ValidateAll() if the designated constraints aren't met.

Config_PulsarMultiError is an error wrapping multiple validation errors returned by Config_Pulsar.ValidateAll() if the designated constraints aren't met.

ConfigMultiError is an error wrapping multiple validation errors returned by Config.ValidateAll() if the designated constraints aren't met.