I saw that issue #60 and the subsequent fix in #61 seemed to touch upon this problem, but I don't quite see how the proposed solution allows one to grab a reference to a KinesisConsumer or ConsumerService. The createConsumer parameter provided by these new factory methods ultimately rely on creation of the consumer within the preStart function of the GraphStageLogic via the underlying stage actor.
My end goal here is to have a reference to my consumer so I can manually start/stop consumption based on custom business logic. Maybe I'm missing something, but please let me know if there's a way to manage this at the moment.
I saw that issue #60 and the subsequent fix in #61 seemed to touch upon this problem, but I don't quite see how the proposed solution allows one to grab a reference to a
KinesisConsumerorConsumerService. ThecreateConsumerparameter provided by these new factory methods ultimately rely on creation of the consumer within thepreStartfunction of theGraphStageLogicvia the underlying stage actor.My end goal here is to have a reference to my consumer so I can manually start/stop consumption based on custom business logic. Maybe I'm missing something, but please let me know if there's a way to manage this at the moment.