Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Interceptor ¶
type Interceptor struct {
Brokers []string
}
func (*Interceptor) OnConsume ¶
func (in *Interceptor) OnConsume(msg *sarama.ConsumerMessage)
func (*Interceptor) OnSend ¶
func (in *Interceptor) OnSend(msg *sarama.ProducerMessage)
Click to show internal directories.
Click to hide internal directories.