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 .
target topic edi_test_compact2
nifi