Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for addToBatch (0.33 sec)

  1. 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)
Back to top