HDFS operator might be required for the maintaining the mapping between the kafka topic to the hdfs directory path where it is stored. This needs to be used by the HDFS writer micro service.