pkg.gl

Categorygithub.com/Alibay/go-kitkafka

package

0.0.0-202411202249

Repository: https://github.com/alibay/go-kit.git

Documentation: pkg.go.dev

# Functions

No description provided by the author

No description provided by the author

NewProducerCfgBuilder

No description provided by the author

NewSubscriberCfgBuilder

No description provided by the author

NewTopicCfgBuilder

No description provided by the author

# Constants

ErrCodeKafkaConnection

No description provided by the author

ErrCodeKafkaCreateTopics

No description provided by the author

ErrCodeKafkaDecodeMsgUnmarshal

No description provided by the author

ErrCodeKafkaFetchMessage

No description provided by the author

ErrCodeKafkaInvalidConfig

No description provided by the author

ErrCodeKafkaMessageContextInvalid

No description provided by the author

ErrCodeKafkaMessageMarshal

No description provided by the author

ErrCodeKafkaMessageWrite

No description provided by the author

ErrCodeKafkaMsgUnmarshalPayload

No description provided by the author

ErrCodeKafkaNotInitialized

No description provided by the author

ErrCodeKafkaProduceMsg

No description provided by the author

ErrCodeKafkaProducerTopicEmpty

No description provided by the author

ErrCodeKafkaSaslGetMechanism

No description provided by the author

ErrCodeKafkaSaslNotSupportedType

No description provided by the author

ErrCodeKafkaSubNoHandlers

No description provided by the author

ErrCodeKafkaSubTopicEmpty

No description provided by the author

No description provided by the author

SaslTypeScramSha256

No description provided by the author

SaslTypeScramSha512

No description provided by the author

# Variables

ErrKafkaConnection

No description provided by the author

ErrKafkaCreateTopics

No description provided by the author

ErrKafkaDecodeMsgUnmarshal

No description provided by the author

ErrKafkaFetchMessage

No description provided by the author

ErrKafkaInvalidConfig

No description provided by the author

ErrKafkaMessageContextInvalid

No description provided by the author

ErrKafkaMessageMarshal

No description provided by the author

ErrKafkaMessageWrite

No description provided by the author

ErrKafkaMsgUnmarshalPayload

No description provided by the author

ErrKafkaNotInitialized

No description provided by the author

ErrKafkaProduceMsg

No description provided by the author

ErrKafkaProducerTopicEmpty

No description provided by the author

ErrKafkaSaslGetMechanism

No description provided by the author

ErrKafkaSaslNotSupportedType

No description provided by the author

ErrKafkaSubNoHandlers

No description provided by the author

ErrKafkaSubTopicEmpty

No description provided by the author

# Structs

BrokerConfig kafka broker configuration.

No description provided by the author

No description provided by the author

ProducerConfig specifies producer config params use builder rather than manual population.

No description provided by the author

SubscriberConfig

SubscriberConfig specifies subscriber config params use builder rather than manual population.

TopicConfig topic config.

No description provided by the author

# Interfaces

Broker kafka.

Producer allows sending message to broker.

ProducerConfigBuilder

No description provided by the author

SubscriberConfigBuilder

No description provided by the author

TopicBuilder simplifies preparing topic config.

# Type aliases

HandlerFn handler function.