client.go

package main

import (
	"context"
	"time"

	proto "github.com/micro-in-cn/tutorials/examples/broker/nsq/proto"
	"github.com/micro/go-micro/v2"
	log "github.com/micro/go-micro/v2/logger"
)

func main() {
	srv := micro.NewService(
		micro.Name("go.micro.broker.kafka.client"),
	)

	srv.Init()

	pub := micro.NewEvent("go.micro.learning.topic.log", srv.Client())
	go func() {
		for i := 0; i < 10; i++ {
			time.Sleep(1 * time.Second)

			_ = pub.Publish(context.TODO(), &proto.DemoEvent{
				Id:      int32(i),
				Current: time.Now().Unix(),
			})
		}
	}()

	if err := srv.Run(); err != nil {
		log.Fatalf("error occurs: %v", err)
	}
}