OK. So basically, I will stick to my 1st thought : put headers from amqp messages into "blunt" field and use mutate filter to pass the information into these attributes.