Support Questions

Find answers, ask questions, and share your expertise

NIFI - unable to replicate null message(tombstones) between kafka topics

avatar
Contributor

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

 

target topic edi_test_compact2

Screenshot 2023-08-28 at 9.47.41.png

 

nifi 

Screenshot 2023-08-28 at 9.52.19.pngScreenshot 2023-08-28 at 9.52.51.png

0 REPLIES 0