- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for CommitTxn (0.06 sec)
-
internal/event/target/kafka.go
} if target.producer != nil { if target.store != nil { // It is safe to abort the current transaction if // queue_dir is configured target.producer.AbortTxn() } else { target.producer.CommitTxn() } target.producer.Close() return target.client.Close() } return nil } func (target *KafkaTarget) init() error { return target.initOnce.Do(target.initKafka) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0)