Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Publisher ¶
type Publisher struct {
*kafka.Publisher
PartitionKey kafka.GeneratePartitionKey
Key string
Config *config.Configuration `inject:"config"`
}
type Subscriber ¶
type Subscriber struct {
*kafka.Subscriber
Conf *config.Configuration `inject:"config"`
}
func (*Subscriber) Consume ¶
func (c *Subscriber) Consume(topic string, messages <-chan *message.Message)
func (*Subscriber) Shutdown ¶
func (s *Subscriber) Shutdown() error
func (*Subscriber) Startup ¶
func (s *Subscriber) Startup() error
Source Files
Click to show internal directories.
Click to hide internal directories.