Collector RabbitMQ and Enrich RabbitMQ released

I think this answer will help you: Kafka Pipeline message format docs - #4 by stanch