Created 06-01-2021 11:56 AM
Created 06-01-2021 12:31 PM
PublishKafka sends the entire flow file to Kafka as a single message. PublishKafkaRecord splits each "record" (e.g. row) in the flow file and sends each record as a message.
References:
1. PublishKafka: https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-9-nar/1.6.0/org.apach...
2. PublishKafkaRecord: https://nifi.apache.org/docs/nifi-docs/components/nifi-docs/components/org.apache.nifi/nifi-kafka-2-...
Created 06-01-2021 12:31 PM
PublishKafka sends the entire flow file to Kafka as a single message. PublishKafkaRecord splits each "record" (e.g. row) in the flow file and sends each record as a message.
References:
1. PublishKafka: https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-9-nar/1.6.0/org.apach...
2. PublishKafkaRecord: https://nifi.apache.org/docs/nifi-docs/components/nifi-docs/components/org.apache.nifi/nifi-kafka-2-...
Created 06-01-2021 12:44 PM
So if I have used JSON transformations on my data and each time 100 flow file are generated so I guess both will be equivalent ...
Created 06-01-2021 12:56 PM
If your files contain one record each, then yes, these NiFi processors will be equivalent.