flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Elias Levy <fearsome.lucid...@gmail.com>
Subject Re: Flink flick cancel vs stop
Date Fri, 15 Sep 2017 18:17:47 GMT
On Fri, Sep 15, 2017 at 10:02 AM, Eron Wright <eronwright@gmail.com> wrote:

> Aljoscha, would it be correct to characterize your idea as a 'pull' source
> rather than the current 'push'?  It would be interesting to look at the
> existing connectors to see how hard it would be to reverse their
> orientation.   e.g. the source might require a buffer pool.

The Kafka client works that way.  As does the QueueingConsumer used by the
RabbitMQ source.  The Kinesis and NiFi sources also seems to poll. Those
are all the bundled sources.

View raw message