Moved path, name from avro model to kafka message key to avoid duplicates.
Added fileName as partition key to maintain file bits instead of parametrized exact partition.
Removed unnecessary parameters.