sinks: process phase-queued messages via new ._run() method

WallarooLabs / wally

Distributed Stream Processing

https://www.wallaroolabs.com

Apache License 2.0

1.48k stars 69 forks source link

sinks: process phase-queued messages via new ._run() method #3115

Closed slfritchie closed 4 years ago

slfritchie commented 4 years ago

PR #3103 (ConnectorSink 2PC overhaul) added a new method QueuedMessage._run() to allow sinks to properly re-process messages queued by the sink phase processor. That PR updated ConnectorSink but not TCPSink or KafkaSink; those classes are updated by this PR.

Fixes #3097