consumers

Documentation

Index

• type Consumer
  • func (c *Consumer) NotificationSubscribeAndListen() error
  • func (c *Consumer) OrderSubscribeAndListen() error
  • func (c *Consumer) ShipperSubscribeAndListen() error
  • func (c *Consumer) WarehouseSubscribeAndListen() error

Types

type Consumer

type Consumer struct {
	Broker string
	Group  string
	Topic  string
}

Consumer represents the subscription to a specified Kafka topic

func (*Consumer) NotificationSubscribeAndListen

func (c *Consumer) NotificationSubscribeAndListen() error

NotificationSubscribeAndListen will subscribe to a Kafka topic and start polling and listening for events Adpated from https://github.com/confluentinc/confluent-kafka-go#examples

func (*Consumer) OrderSubscribeAndListen

func (c *Consumer) OrderSubscribeAndListen() error

OrderSubscribeAndListen will subscribe to a Kafka topic and start polling and listening for events Adpated from https://github.com/confluentinc/confluent-kafka-go#examples

func (*Consumer) ShipperSubscribeAndListen

func (c *Consumer) ShipperSubscribeAndListen() error

ShipperSubscribeAndListen will subscribe to a Kafka topic and start polling and listening for events Adpated from https://github.com/confluentinc/confluent-kafka-go#examples

func (*Consumer) WarehouseSubscribeAndListen

func (c *Consumer) WarehouseSubscribeAndListen() error

WarehouseSubscribeAndListen will subscribe to a Kafka topic and start polling and listening for events Adpated from https://github.com/confluentinc/confluent-kafka-go#examples