This is an automated email from the ASF dual-hosted git repository.
mdedetrich pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
from 7100b50d6 [jms] close sessions when exceptions happen (#485)
new 26674de73 kinesis: use stage materializer with IODispatcher instead of
injected execution context
new a5b5a310c use separate thread
new 1b5df0eac applyCodeStyle
new f8046eaaf remove unnecessary Source.fromMaterializer
new b8bb89e7f revert to Future but using IODispatcher
new 4eb10dda9 test showing the thread starvation
new e710d4725 using a separate thread works
new 681d9e6db Revert "using a separate thread works"
new ddea46df3 Revert "test showing the thread starvation"
new 87b6625f0 fix postStop so shutdown is not done in a fire-forget future
new 67a3fd682 scalafmt
The 11 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../kinesis/impl/KinesisSchedulerSourceStage.scala | 21 +++++++++++++++++++--
.../kinesis/scaladsl/KinesisSchedulerSource.scala | 9 +--------
2 files changed, 20 insertions(+), 10 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
