Hello there, i want to write a simple messages broker that if a message with a specific topic arrives the broker will write it to hdfs (using JAVA HDFS API). have you any ideas how to recognize (from the broker side) if a specific message of a topic arrives from a producer? Then how to persistently save it anywhere else except the default persisten storage?
thanks in advance, Petrucci