Documentation ¶
Overview ¶
kafka @author LanguageY++2013 2023/5/11 09:33 @company soulgame
kafka @author LanguageY++2013 2023/5/11 09:54 @company soulgame
Index ¶
- type KafkaPublisher
- type KafkaSubscriber
- func (s *KafkaSubscriber) Cleanup(ses sarama.ConsumerGroupSession) error
- func (s *KafkaSubscriber) ConsumeClaim(ses sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) (retErr error)
- func (s KafkaSubscriber) Name() string
- func (s *KafkaSubscriber) Setup(ses sarama.ConsumerGroupSession) error
- func (s *KafkaSubscriber) Start()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaPublisher ¶
type KafkaPublisher struct {
// contains filtered or unexported fields
}
func NewKafkaPublisher ¶
func NewKafkaPublisher(brokerList []string) *KafkaPublisher
func (KafkaPublisher) Name ¶
func (p KafkaPublisher) Name() string
func (*KafkaPublisher) Send ¶
func (p *KafkaPublisher) Send(topic string, ev *open.MatchEvent) error
type KafkaSubscriber ¶
type KafkaSubscriber struct { pubsub.EventHandlers // contains filtered or unexported fields }
func NewKafkaSubscriber ¶
func NewKafkaSubscriber(brokerList []string, topics []string, group string) (*KafkaSubscriber, error)
func (*KafkaSubscriber) Cleanup ¶
func (s *KafkaSubscriber) Cleanup(ses sarama.ConsumerGroupSession) error
func (*KafkaSubscriber) ConsumeClaim ¶
func (s *KafkaSubscriber) ConsumeClaim(ses sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) (retErr error)
func (KafkaSubscriber) Name ¶
func (s KafkaSubscriber) Name() string
func (*KafkaSubscriber) Setup ¶
func (s *KafkaSubscriber) Setup(ses sarama.ConsumerGroupSession) error
func (*KafkaSubscriber) Start ¶
func (s *KafkaSubscriber) Start()
Click to show internal directories.
Click to hide internal directories.