kafka

Jan 9, 2023

Changes in this version

type Producer

+ func (producer *Producer) SendKafkaMsg(ctx context.Context, topic, key string, req proto.Message, eventType int32) error

Oct 8, 2022

Changes in this version

+ const TopicRelationCacheRebuild

+ const TopicRelationFollow

+ const TopicRelationOperator

Sep 9, 2022

Changes in this version

+ const EventTypeCreate

+ const EventTypeDelete

+ const EventTypeHate

+ const EventTypeLike

+ const EventTypeListMissed

+ const EventTypeReply

+ const EventTypeSubListMissed

+ const TopicCommentCacheRebuild

+ const TopicCommentOperator

+ const TopicCommentPublish

+ const TopicOpusOperator

Aug 28, 2022

Changes in this version

+ type Consumer struct

+ func InitConsumer(broker, topics []string, group string, apiLogger, excLogger *log.Logger) (*Consumer, error)

+ func (consumer *Consumer) Start(fn func(ctx context.Context, msg *KafkaMessage))

+ func (consumer *Consumer) Stop() error

+ type KafkaMessage struct

+ EventType int32

+ Message []byte

+ TraceId string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*KafkaMessage) Descriptor() ([]byte, []int)

+ func (*KafkaMessage) ProtoMessage()

+ func (dst *KafkaMessage) XXX_Merge(src proto.Message)

+ func (m *KafkaMessage) GetEventType() int32

+ func (m *KafkaMessage) GetMessage() []byte

+ func (m *KafkaMessage) GetTraceId() string

+ func (m *KafkaMessage) Reset()

+ func (m *KafkaMessage) String() string

+ func (m *KafkaMessage) XXX_DiscardUnknown()

+ func (m *KafkaMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *KafkaMessage) XXX_Size() int

+ func (m *KafkaMessage) XXX_Unmarshal(b []byte) error

+ type Producer struct

+ func InitKafkaProducer(addr []string, apiLogger, excLogger *log.Logger) (*Producer, error)

+ func (producer *Producer) SendMessage(topic string, key []byte, data []byte) error

+ func (producer *Producer) Stop() error