Skip to content
This repository has been archived by the owner on Oct 23, 2023. It is now read-only.

Commit

Permalink
Tweak documentation on consumer shutdown method call (#52)
Browse files Browse the repository at this point in the history
See #51
  • Loading branch information
TJC authored and markglh committed Feb 2, 2018
1 parent f6aaeb7 commit 6ae4b06
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -331,7 +331,7 @@ A `KinesisConsumer` is used internally for the `Kinesis.source`. All rules descr
### Graceful Shutdown

Currently the KinesisConsumer Shutdown works as follows:
* Shutdown is called on the `KinesisConsumer` (either explicitly or via the jvm shutdown hook)
* `stop()` is called on the `KinesisConsumer` (either explicitly or via the jvm shutdown hook)
* This then calls `requestShutdown` on the KCL Worker, blocking until completion.
* The KCL Worker propagates this down to the `ConsumerProcessingManager` (Which is the `IRecordProcessor`) - calling `shutdownRequested` on each instance (one per shard).
* When `shutdownRequested` is called, this sends a `GracefulShutdown` message to the `ConsumerWorker` Actor, blocking until a response is received (Ask + Await).
Expand Down

0 comments on commit 6ae4b06

Please sign in to comment.