Fix documentation and example.
Fix consumers list access race condition.
go fmt