# ELASTIC STREAM

1. Graceful shutdown of Workers. It has start() so it should have stop() also.
2. Channel buffer should be configurable or not? Is it same as batchSize?
3. Each data(record) should have its position.
4. Worker has *Client in it. Is this OK?
5. Polling(ticker)?
6. Context use.
7. Teardown() and Ack().