Add flushing final bulk while graceful shutdown (#4)

Trendyol · Apr 4, 2023 · 950e3de · 950e3de
1 parent c990d0e
commit 950e3de
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/connector.go b/connector.go
@@ -31,6 +31,7 @@ func (c *connector) Start() {
 
 func (c *connector) Close() {
 	c.dcp.Close()
+	c.bulk.Close()
 }
 
 func (c *connector) listener(ctx *models.ListenerContext) {