Nifi version is 1.23.2 and kafka version 2.6.I use ConsumeKafka_1_0 1.23.2 to read messages from kafka.DetectDuplicate 1.23.2 processor is available, which deduplicates stream files on the same stream.However, stream read the same recording twice and DetectDuplicate processor could not deduplicate the same message.I understand that it reads the same message because the offset id value is same in two message.What could be the reason why the ConsumeKafka_1_0 processor reads the same message and DetectDuplicate processor cannot detect same message?
