go_delay_driver_kafka

package module
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 4, 2021 License: Apache-2.0 Imports: 4 Imported by: 1

README

go-driver-kafka

how to use

https://github.com/wsqun/go-delay-queue

docker测试环境

将$IP替换为本地IP,通过ipconfig或者ifconfig获取,如192.168.1.37

  • 安装Zookeeper
docker pull zookeeper
docker run -d --name zookeeper -p 2181:2181 zookeeper
  • 安装Kafka
docker pull wurstmeister/kafka
docker run  -d --name kafka -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=$IP:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://$IP:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
  • 安装Kafka管理后台
docker pull kafkamanager/kafka-manager
docker run -p 9000:9000 -d -eZK_HOSTS=$IP kafkamanager/kafka-manager

访问:
http://127.0.0.1:9000/

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DKafka

type DKafka struct {
	// contains filtered or unexported fields
}

func NewDKafka

func NewDKafka(addrs []string, groupId string, ctx context.Context, wg *sync.WaitGroup, opt ...OptFn) (dk *DKafka, err error)

func NewOnlyProduct added in v1.0.3

func NewOnlyProduct(addrs []string, opt ...OptFn) (dk *DKafka, err error)

当只需要生产消息可只调用该方法,初始化生产者

func (*DKafka) PublishMsg

func (dk *DKafka) PublishMsg(topic string, msg []byte) (err error)

func (*DKafka) SubscribeMsg

func (dk *DKafka) SubscribeMsg(topic string, dealFn func([]byte) (err error)) (err error)

type OptFn

type OptFn func(cfg *sarama.Config)

Jump to

Keyboard shortcuts

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