kafka_client

package

v1.1.0 Latest Latest Go to latest Published: Nov 7, 2024 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/saperliu/common-tool

Links

Open Source Insights

Documentation ¶

Index ¶

type ClientKafka

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ClientKafka ¶

type ClientKafka struct {
	ProducerTopic string
	ConsumerTopic string
	BrokerList    []string
	GroupId       string
	Producer      *healer.Producer
	Consumer      <-chan *healer.FullMessage
	SegConsumer   *kafka.Reader
}

func (*ClientKafka) NewConsumer ¶

func (ka *ClientKafka) NewConsumer(topic string) (<-chan *healer.FullMessage, error)

func (*ClientKafka) NewKafkaConsumer ¶

func (ka *ClientKafka) NewKafkaConsumer(topic string) *kafka.Reader

func (*ClientKafka) NewProducer ¶

func (ka *ClientKafka) NewProducer(topic string) (pro *healer.Producer, err error)

func (*ClientKafka) SendMessage ¶

func (ka *ClientKafka) SendMessage(key string, value string) error

Source Files ¶

View all Source files

client_kafka.go

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