fix: empty debezium values

Author: Angular2Guy

database-to-rest/src/main/java/de/xxx/dbtorest/source/DbChangeSourceService.java

@@ -1,14 +1,14 @@
 /**
- *    Copyright 2023 Sven Loesekann
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
- http://www.apache.org/licenses/LICENSE-2.0
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
+ * Copyright 2023 Sven Loesekann
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
  */
 package de.xxx.dbtorest.source;
 
@@ -19,6 +19,9 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.Optional;
+import java.util.function.Predicate;
+
 @Service
 @Transactional
 public class DbChangeSourceService {
@@ -31,6 +34,7 @@ public DbChangeSourceService(KafkaProducer kafkaProducer) {
 
     public void sendChange(DbChangeDto dbChangeDto) {
         //LOGGER.info(dbChangeDto.toString());
-        this.kafkaProducer.sendDbChangeMsg(dbChangeDto);
+        Optional.ofNullable(dbChangeDto.value()).stream().filter(Predicate.not(String::isBlank)).findFirst()
+                .ifPresent(x -> this.kafkaProducer.sendDbChangeMsg(dbChangeDto));
     }
 }