RE: kafka as recovery only source

: user@flink.apache.org; Tzu-Li (Gordon) Tai <tzuli...@apache.org> Subject: Re: kafka as recovery only source Hi Tovi, I've been thinking about this idea. It might be possible, but I think you have to implement a custom source for this. I don't think it would work to have the JMSConsume

Re: kafka as recovery only source

Hi Tovi, I've been thinking about this idea. It might be possible, but I think you have to implement a custom source for this. I don't think it would work to have the JMSConsumer, KafkaSink, and RecoverySource in separate operators because otherwise it would not be possible to share the Kafka