Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]
Created on
10-07-2019
03:37 AM
- last edited on
10-07-2019
08:08 AM
by
ask_bill_brooks
Hey, folks,
I have a Kerberized server, and for the police I'm using Ranger, via console I can publish and consume the messages of Kafka, But now I must do through Nifi and that I'm very lost someone could help me.
Thank you
Created 10-08-2019 10:00 AM
You can try below flow which is just for testing purposes:
Basically I have a tailFile processor passing data through splitText then these messages are sent to PublishKafka_1_0(use this processor for this test), finally I created a consumer to consume data from the same topic configured in PublishKafka_1_0 storing the data in the file system with putFile.
In putFile I have configured Maximum File Count to 10, to avoid excessive space usage in the file system.
Created 10-07-2019 11:59 AM
You can start testing a flow like below:
tailFile --> PublishKafka_1_0(2_0 depending on your Kafka version)
In publishKafka you can use a configuration example like below:
Created 10-08-2019 12:26 AM
Hello ManuelCalvo
I don't know if it's asking you too much, as I would have to do a relationship of publisher and consumer. I'm a little new to the subject of Big data. Thank you very much for the info.
Greetings
Created 10-08-2019 10:00 AM
You can try below flow which is just for testing purposes:
Basically I have a tailFile processor passing data through splitText then these messages are sent to PublishKafka_1_0(use this processor for this test), finally I created a consumer to consume data from the same topic configured in PublishKafka_1_0 storing the data in the file system with putFile.
In putFile I have configured Maximum File Count to 10, to avoid excessive space usage in the file system.