From 950e3de739e84b571b0e8caffa1a8e991ebf3292 Mon Sep 17 00:00:00 2001
From: Mehmet Sezer <m.szr98@gmail.com>
Date: Tue, 4 Apr 2023 09:12:53 +0300
Subject: [PATCH] Add flushing final bulk while graceful shutdown (#4)

---
 connector.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/connector.go b/connector.go
index d0f4ae7..6022ce7 100644
--- 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) {