kafkaclient

README

kafkaclient

Golang kafka package to simplify te consumer and producer usage

Install

go get github.com/san-services/kafkaclient

Consumer

func onMessageReceived(topic string, message string){
  // do stuff with message
}


// listen to test topic
client := kafkaclient.New("localhost:9092", "group1", onMessageReceived)
go client.ListenToTopic(context.Background(), "test")

Producer

client := kafkaclient.New("localhost:9092", "producerGroup", nil)

// produce message to test topic
err := client.ProduceToTopic("test", "this is a test message")

if err != nil {
  // handle error...
}

Documentation

Index

• type KafkaClient
  • func New(server string, groupID string, onMessageReceived onMessage) *KafkaClient
  • func (kc *KafkaClient) ListenToTopic(ctx context.Context, topic string)
  • func (kc *KafkaClient) ProduceToTopic(ctx context.Context, topic string, message string) error

Types

type KafkaClient

type KafkaClient struct {
	Server            string
	GroupID           string
	OnMessageReceived onMessage
}

KafkaClient ...

func New

func New(server string, groupID string, onMessageReceived onMessage) *KafkaClient

New creates broker object

func (*KafkaClient) ListenToTopic

func (kc *KafkaClient) ListenToTopic(ctx context.Context, topic string)

ListenToTopic starts listening for the specified topic

func (*KafkaClient) ProduceToTopic

func (kc *KafkaClient) ProduceToTopic(ctx context.Context, topic string, message string) error

ProduceToTopic Sends a message to the specified topic