Adding source name to kafka headers