Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DefaultKafkaEventConsumer ¶
type DefaultKafkaEventConsumer struct {
// contains filtered or unexported fields
}
func (*DefaultKafkaEventConsumer) MessageChannel ¶
func (k *DefaultKafkaEventConsumer) MessageChannel() <-chan *sarama.ConsumerMessage
type DefaultKafkaEventProducer ¶
type DefaultKafkaEventProducer struct {
// contains filtered or unexported fields
}
func (*DefaultKafkaEventProducer) Close ¶
func (k *DefaultKafkaEventProducer) Close()
func (*DefaultKafkaEventProducer) Produce ¶
func (k *DefaultKafkaEventProducer) Produce(event event.KafkaEvent) error
type KafkaConsumerGroupHandler ¶
type KafkaConsumerGroupHandler struct {
// contains filtered or unexported fields
}
func (*KafkaConsumerGroupHandler) Cleanup ¶
func (h *KafkaConsumerGroupHandler) Cleanup(cgs sarama.ConsumerGroupSession) error
func (*KafkaConsumerGroupHandler) ConsumeClaim ¶
func (h *KafkaConsumerGroupHandler) ConsumeClaim(cgs sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (*KafkaConsumerGroupHandler) Setup ¶
func (h *KafkaConsumerGroupHandler) Setup(cgs sarama.ConsumerGroupSession) error
type KafkaEventConsumer ¶
type KafkaEventConsumer interface {
MessageChannel() <-chan *sarama.ConsumerMessage
}
func NewKafkaEventConsumer ¶
func NewKafkaEventConsumer(brokerHosts []string, topic string, groupId string) (KafkaEventConsumer, error)
handle gracefull shutdown
type KafkaEventProducer ¶
type KafkaEventProducer interface {
Produce(event event.KafkaEvent) error
Close()
}
func NewKafkaEventProducer ¶
func NewKafkaEventProducer(brokerHosts []string, topic string) KafkaEventProducer
Source Files
Click to show internal directories.
Click to hide internal directories.