PR for fluent + event bus write stream