- Improve producer code.
- Add consumer implementation.