Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
Message is an abstraction based around kafka.Message
type MessageInterface ¶
type MessageInterface interface {
GetKey() []byte
GetValue() interface{}
}
MessageInterface is an abstraction on top of kafka.Message
func NewMessage ¶
func NewMessage(key string, value interface{}) MessageInterface
NewMessage creates a new object implementing MessageInterface
type Producer ¶
type Producer struct {
// contains filtered or unexported fields
}
Producer is the implementation of a kafka publisher it will autorefresh tls secrets automatically can be configured with multiple writers, each of those will need a nickname and will be known by that when calling the Publish method
func NewProducer ¶
func NewProducer(monitor monitoring.MonitorInterface, refreshables ...core.RefreshableInterface) *Producer
NewProducer creates a new object implementing ProducerInterface
func (*Producer) ListTopics ¶
ListTopics returns a list of topics with their nicknames
Source Files
Click to show internal directories.
Click to hide internal directories.