consumer

Documentation

Index

• Constants
• type Consumer
  • func NewConsumer(conig ConsumerConfig) *Consumer
  • func (c *Consumer) ReadMessage(interval time.Duration) (api.Message, error)
  • func (c *Consumer) SubscribeToTopic(topic string, Partition int)
• type ConsumerConfig

Constants

const BROKER_URL = "http://localhost:3000"

Types

type Consumer

type Consumer struct {
	Offset    int
	Topic     string
	Partition int
	// contains filtered or unexported fields
}

Consumers will contains their own offset that will tell them till wher they have already fetched the messages

func NewConsumer

func NewConsumer(conig ConsumerConfig) *Consumer

NewConsumer will create a new consumer

func (*Consumer) ReadMessage

func (c *Consumer) ReadMessage(interval time.Duration) (api.Message, error)

func (*Consumer) SubscribeToTopic

func (c *Consumer) SubscribeToTopic(topic string, Partition int)

type ConsumerConfig

type ConsumerConfig struct {
}