kafka

package

v0.0.0-...-7b6d186 Latest Latest Go to latest Published: Jan 14, 2021 License: MIT Imports: 7 Imported by: 0

Documentation ¶

Index ¶

Variables
func Consume(ctx context.Context, brokers []string, topicPattern string, ...)
type Message
- func NewMessage(msg kafka.Message) (*Message, error)
- func (m *Message) QualifiedTablename() string

Constants ¶

This section is empty.

Variables ¶

View Source

var Logger *logrus.Entry

Logger provides access to the Kafka specific logging facility

Functions ¶

func Consume ¶

func Consume(ctx context.Context, brokers []string, topicPattern string, messages chan<- Message)

Consume function receives messages from Kafka and sends them to the `messages` channel

Types ¶

type Message ¶

type Message struct {
	kafka.Message
	Op         string
	TableName  string
	SchemaName string
	Keys       map[string]interface{}
	Values     map[string]interface{}
}

Message is a data structure representing kafka messages

func NewMessage ¶

func NewMessage(msg kafka.Message) (*Message, error)

NewMessage used to create and init a new message instance

func (*Message) QualifiedTablename ¶

func (m *Message) QualifiedTablename() string

Source Files ¶

View all Source files

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