- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for addToBatch (0.33 sec)
-
internal/event/target/kafka.go
if err := target.init(); err != nil { return err } // If batch is enabled, the event will be batched in memory // and will be committed once the batch is full. if target.batch != nil { return target.addToBatch(key) } eventData, eErr := target.store.Get(key.Name) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0)