Init broker connection when broker object is inserted into metadata cache and not when index rebuild.
Hunting down connection problem
Make Producer executing on scheduler thread to avoid synchronization problems
Fixed flushing producer cleanly