Hi All ,
I'm trying to replicate data between two Kafka topics that are defined with cleanup policy - compact using NIFI 1.21.0 ,The problem is that null messages(tombstones) replicate with a wrong value (no value instead of null ),I'm using PublishKafka_2_6 to insert the data to the target topic.
for example message key 666 .
source topic edi_test_compact .
![Screenshot 2023-08-28 at 9.45.14.png Screenshot 2023-08-28 at 9.45.14.png](https://community.cloudera.com/t5/image/serverpage/image-id/38312i1CCA6FCFCDBC049F/image-size/large?v=v2&px=999)
target topic edi_test_compact2
![Screenshot 2023-08-28 at 9.47.41.png Screenshot 2023-08-28 at 9.47.41.png](https://community.cloudera.com/t5/image/serverpage/image-id/38313iDCBD83A4CC91BAAD/image-size/large?v=v2&px=999)
nifi
![Screenshot 2023-08-28 at 9.52.19.png Screenshot 2023-08-28 at 9.52.19.png](https://community.cloudera.com/t5/image/serverpage/image-id/38314i7EFD88A926A456C8/image-size/large?v=v2&px=999)
![Screenshot 2023-08-28 at 9.52.51.png Screenshot 2023-08-28 at 9.52.51.png](https://community.cloudera.com/t5/image/serverpage/image-id/38315i483E694C72F1EF48/image-size/large?v=v2&px=999)