pkg.gl

Categorygithub.com/aykanferhat/go-kafka-partition-scalerpkgkafka

package

0.0.7

Repository: https://github.com/aykanferhat/go-kafka-partition-scaler.git

Documentation: pkg.go.dev

# Packages

config

No description provided by the author

handler

No description provided by the author

message

No description provided by the author

sarama

No description provided by the author

# Functions

NewAdmin

No description provided by the author

NewAuthConfig

No description provided by the author

NewConsumerGroup

No description provided by the author

NewMockConsumerGroup

NewMockConsumerGroup creates a new mock instance.

NewMockProducer

NewMockProducer creates a new mock instance.

NewProducer

No description provided by the author

NewProducerConfig

No description provided by the author

# Variables

CompressionNone

No description provided by the author

WaitForLocal

No description provided by the author

# Structs

MockConsumerGroup

MockConsumerGroup is a mock of ConsumerGroup interface.

MockConsumerGroupMockRecorder

MockConsumerGroupMockRecorder is the mock recorder for MockConsumerGroup.

MockProducer

MockProducer is a mock of Producer interface.

MockProducerMockRecorder

MockProducerMockRecorder is the mock recorder for MockProducer.

# Interfaces

Admin

No description provided by the author

ConsumerGroup

No description provided by the author

Producer

No description provided by the author

# Type aliases

ClusterConfig

No description provided by the author

CommitMessageFunc

No description provided by the author

ConsumerGroupConfig

No description provided by the author

ConsumerMessage

No description provided by the author

ConsumerStatusHandler

No description provided by the author

MessageHandler

No description provided by the author