THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Sometimes, user will want to close a producer wiithin a bounded time to avoid blocking on producer.close() for too long.
- One specific use case of 1) is that in some scenarios, user will want to close the produce immediately and fail all the unsent messages in RecordAccumulator. Some examples are:
- In mirror maker, if a send failed, we don't want to continue sending messages in RecordAccumulator to avoid reordering.
- For people who are using deployment tools, a service is expected to stop in given time. In that case people might want to have a bounded time to shutdown producer.
So we need to provide an interface that allow user to choose to close producer in which way.
...