- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for sendMultiple (0.16 sec)
-
internal/event/target/kafka.go
} msg, err := target.toProducerMessage(eventData) if err != nil { return err } _, _, err = target.producer.SendMessage(msg) return err } // sendMultiple sends multiple messages to the kafka. func (target *KafkaTarget) sendMultiple(events []event.Event) error { if target.producer == nil { return store.ErrNotConnected } var msgs []*sarama.ProducerMessage for _, event := range events {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0)