diff --git a/src/Producer/SyncProcess.php b/src/Producer/SyncProcess.php index d09096f9..f5ff9c2a 100644 --- a/src/Producer/SyncProcess.php +++ b/src/Producer/SyncProcess.php @@ -125,7 +125,7 @@ protected function convertMessage($data) } if (! isset($value['value']) || ! trim($value['value'])) { - continue; + $value['value'] = null; } if (! isset($value['key'])) {