kafka_go

package module

Go to main page

Versions in this module

v1

v1.0.29

May 11, 2023

v1.0.28

May 10, 2023

v1.0.27

May 8, 2023

v1.0.26

May 8, 2023

v1.0.25

Apr 15, 2023

v1.0.23

Apr 15, 2023

v1.0.22

Feb 8, 2023

Changes in this version

type BuildProduct

+ func (this *BuildProduct) GetTransactional() bool

type BuildProductApi

+ GetTransactional func() bool

+ SetAckType func(ackType ProductAckType) BuildProductApi

v1.0.21

Jan 11, 2023

Changes in this version

type BalanceType

+ const CONSUMER_BALANCE_STRATEGY_RANGE

+ const CONSUMER_BALANCE_STRATEGY_ROUNDROBIN

+ const CONSUMER_BALANCE_STRATEGY_STICKY

type BuildConsumer

+ func (this *BuildConsumer) IsMultiplePartition() bool

+ func (this *BuildConsumer) SetBalanceType(balanceType BalanceType) BuildConsumerApi

+ func (this *BuildConsumer) SetMultiplePartition(isMultiplePartition bool) BuildConsumerApi

type BuildConsumerApi

+ IsMultiplePartition func() bool

+ SetBalanceType func(balanceType BalanceType) BuildConsumerApi

+ SetMultiplePartition func(isMultiplePartition bool) BuildConsumerApi

v1.0.20

Jan 10, 2023

Changes in this version

+ const DEFAULT_MAX_CONNECTION

+ const PRODUCT_ACK_TYPE_ALL

+ const PRODUCT_ACK_TYPE_FOLLOWER

+ const PRODUCT_ACK_TYPE_NORNAL

+ const PRODUCT_CONN_STRATEGY_BALANCE_ROUNDROBIN

+ var KAFKA_CONSUMER_ERROR_BUILD_EMPTY = errors.New("consumer build len can not be empty")

+ var KAFKA_PRODUCT_ERROR_BUILD_CLIENT_EMPTY = errors.New("product client empty")

+ var KAFKA_PRODUCT_ERROR_BUILD_CLIENT_NIL = errors.New("product client nil")

+ var KAFKA_PRODUCT_ERROR_BUILD_EMPTY = errors.New("product build len can not be empty")

+ var KAFKA_PRODUCT_ERROR_BUILD_NAME_EMPTY = errors.New("product build name can not be empty")

+ func NewFactoryConsumer() *factoryConsumer

+ func NewFactoryConsumerBackGround() *factoryConsumer

+ func NewFactoryProduct() *factoryProduct

+ type AckLevel int

+ type BalanceType int

+ const BALANCE_STRATEGY_RANGE

+ const BALANCE_STRATEGY_ROUNDROBIN

+ const BALANCE_STRATEGY_STICKY

+ type BuildConsumer struct

+ func (this *BuildConsumer) GetAddr() string

+ func (this *BuildConsumer) GetBalanceType() BalanceType

+ func (this *BuildConsumer) GetConfig() *sarama.Config

+ func (this *BuildConsumer) GetGroupId() string

+ func (this *BuildConsumer) GetKafkaVersion() string

+ func (this *BuildConsumer) GetResponseListener() ConsumerResponseListener

+ func (this *BuildConsumer) GetTopic() string

+ func (this *BuildConsumer) IsAutoCommit() bool

+ func (this *BuildConsumer) IsDebug() bool

+ func (this *BuildConsumer) IsOldOffset() bool

+ func (this *BuildConsumer) SetConfig(config *sarama.Config) BuildConsumerApi

+ func (this *BuildConsumer) SetDebug(isDebug bool) BuildConsumerApi

+ func (this *BuildConsumer) SetIsAutoCommit(autoCommit bool) BuildConsumerApi

+ func (this *BuildConsumer) SetKafkaVersion(kafkaVersion string) BuildConsumerApi

+ func (this *BuildConsumer) SetResponseListener(responseListener ConsumerResponseListener) BuildConsumerApi

+ func (this *BuildConsumer) ToString() string

+ type BuildConsumerApi interface

+ GetAddr func() string

+ GetBalanceType func() BalanceType

+ GetConfig func() *sarama.Config

+ GetGroupId func() string

+ GetKafkaVersion func() string

+ GetResponseListener func() ConsumerResponseListener

+ GetTopic func() string

+ IsAutoCommit func() bool

+ IsDebug func() bool

+ IsOldOffset func() bool

+ SetConfig func(config *sarama.Config) BuildConsumerApi

+ SetDebug func(isDebug bool) BuildConsumerApi

+ SetIsAutoCommit func(autoCommit bool) BuildConsumerApi

+ SetKafkaVersion func(kafkaVersion string) BuildConsumerApi

+ SetResponseListener func(responseResult ConsumerResponseListener) BuildConsumerApi

+ ToString func() string

+ func NewBuildConsumer(addr string, groupId string, topic string) BuildConsumerApi

+ func NewBuildConsumerStrategy(addr string, groupId string, topic string, balanceType BalanceType) BuildConsumerApi

+ func NewNewBuildConsumerOffset(addr string, groupId string, topic string, balanceType BalanceType, ...) BuildConsumerApi

+ type BuildProduct struct

+ func (this *BuildProduct) GetAddr() string

+ func (this *BuildProduct) GetAddrSlice() []string

+ func (this *BuildProduct) GetConfig() *sarama.Config

+ func (this *BuildProduct) GetConnStrategy() ProductBalanceType

+ func (this *BuildProduct) GetHashCode() int64

+ func (this *BuildProduct) GetHashCodeString() string

+ func (this *BuildProduct) GetMaxConnection() int32

+ func (this *BuildProduct) GetName() string

+ func (this *BuildProduct) SetAckType(ackType ProductAckType) BuildProductApi

+ func (this *BuildProduct) SetConfig(config *sarama.Config) BuildProductApi

+ func (this *BuildProduct) SetDebug(isDebug bool) BuildProductApi

+ func (this *BuildProduct) SetMaxConnection(maxConnection int32) BuildProductApi

+ func (this *BuildProduct) SetTransactional(isTransactional bool) BuildProductApi

+ func (this *BuildProduct) ToString() string

+ type BuildProductApi interface

+ GetAddr func() string

+ GetAddrSlice func() []string

+ GetConfig func() *sarama.Config

+ GetConnStrategy func() ProductBalanceType

+ GetHashCode func() int64

+ GetHashCodeString func() string

+ GetMaxConnection func() int32

+ GetName func() string

+ SetConfig func(config *sarama.Config) BuildProductApi

+ SetDebug func(isDebug bool) BuildProductApi

+ SetMaxConnection func(maxConnection int32) BuildProductApi

+ SetTransactional func(isTransactional bool) BuildProductApi

+ ToString func() string

+ func NewBuildProduct(name string, addr string) BuildProductApi

+ type ConsumerMessageContext struct

+ func (this *ConsumerMessageContext) GetBuilder() BuildConsumerApi

+ func (this *ConsumerMessageContext) GetGroupId() string

+ func (this *ConsumerMessageContext) GetMessage() []byte

+ func (this *ConsumerMessageContext) GetMessageString() string

+ func (this *ConsumerMessageContext) GetOffset() int64

+ func (this *ConsumerMessageContext) GetPartition() int32

+ func (this *ConsumerMessageContext) GetSession() *ConsumerSession

+ func (this *ConsumerMessageContext) GetTimeStamp() time.Time

+ func (this *ConsumerMessageContext) GetTopic() string

+ func (this *ConsumerMessageContext) GetVal() *sarama.ConsumerMessage

+ type ConsumerResponseListener func(context *ConsumerMessageContext)

+ type ConsumerSession struct

+ func NewConsumerSession(session sarama.ConsumerGroupSession, message *sarama.ConsumerMessage, ...) *ConsumerSession

+ func (this *ConsumerSession) Ack()

+ func (this *ConsumerSession) GetMessage() *sarama.ConsumerMessage

+ func (this *ConsumerSession) GetSession() sarama.ConsumerGroupSession

+ func (this *ConsumerSession) IsAutoAck() bool

+ type ProductAckType int

+ type ProductBalanceType int

v1.0.19

Jan 10, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL