diff --git a/clients/destination/v0/destination_terminate.go b/clients/destination/v0/destination_terminate.go
index aebd7e8afc..8b025ca53f 100644
--- a/clients/destination/v0/destination_terminate.go
+++ b/clients/destination/v0/destination_terminate.go
@@ -13,10 +13,12 @@ func (c *Client) terminateProcess() error {
 		c.logger.Error().Err(err).Msg("failed to send interrupt signal to destination plugin")
 	}
 	timer := time.AfterFunc(5*time.Second, func() {
+		c.logger.Info().Msg("sending kill signal to destination plugin")
 		if err := c.cmd.Process.Kill(); err != nil {
 			c.logger.Error().Err(err).Msg("failed to kill destination plugin")
 		}
 	})
+	c.logger.Info().Msg("waiting for destination plugin to terminate")
 	st, err := c.cmd.Process.Wait()
 	timer.Stop()
 	if err != nil {
diff --git a/clients/destination/v0/destination_terminate_windows.go b/clients/destination/v0/destination_terminate_windows.go
index 366d19ed24..429363ac3d 100644
--- a/clients/destination/v0/destination_terminate_windows.go
+++ b/clients/destination/v0/destination_terminate_windows.go
@@ -6,6 +6,7 @@ func (c *Client) terminateProcess() error {
 	if err := c.cmd.Process.Kill(); err != nil {
 		c.logger.Error().Err(err).Msg("failed to kill destination plugin")
 	}
+	c.logger.Info().Msg("waiting for destination plugin to terminate")
 	st, err := c.cmd.Process.Wait()
 	if err != nil {
 		return err
diff --git a/clients/source/v1/source_terminate.go b/clients/source/v1/source_terminate.go
index 11e8313fc3..d634837572 100644
--- a/clients/source/v1/source_terminate.go
+++ b/clients/source/v1/source_terminate.go
@@ -13,10 +13,12 @@ func (c *Client) terminateProcess() error {
 		c.logger.Error().Err(err).Msg("failed to send interrupt signal to source plugin")
 	}
 	timer := time.AfterFunc(5*time.Second, func() {
+		c.logger.Info().Msg("sending kill signal to source plugin")
 		if err := c.cmd.Process.Kill(); err != nil {
 			c.logger.Error().Err(err).Msg("failed to kill source plugin")
 		}
 	})
+	c.logger.Info().Msg("waiting for source plugin to terminate")
 	st, err := c.cmd.Process.Wait()
 	timer.Stop()
 	if err != nil {
diff --git a/clients/source/v1/source_terminate_windows.go b/clients/source/v1/source_terminate_windows.go
index e5d993990b..3675655eb8 100644
--- a/clients/source/v1/source_terminate_windows.go
+++ b/clients/source/v1/source_terminate_windows.go
@@ -6,6 +6,7 @@ func (c *Client) terminateProcess() error {
 	if err := c.cmd.Process.Kill(); err != nil {
 		c.logger.Error().Err(err).Msg("failed to kill source plugin")
 	}
+	c.logger.Info().Msg("waiting for source plugin to terminate")
 	st, err := c.cmd.Process.Wait()
 	if err != nil {
 		return err