Thanks, I'll check it out.
On Thu, Sep 5, 2019 at 5:22 AM Fabian Hueske wrote:
> Hi Vishwas,
>
> This is a log statement from Kafka [1].
> Not sure how when AppInfoParser is created (the log message is written by
> the constructor).
>
> For Kafka versions > 1.0, I'd recommend the universal conne
Hi Vishwas,
This is a log statement from Kafka [1].
Not sure how when AppInfoParser is created (the log message is written by
the constructor).
For Kafka versions > 1.0, I'd recommend the universal connector [2].
Not sure how well it works if producers and consumers have different
versions.
Mayb
Hi guys,
I am using flink 1.7.2 and my application consumes from a kafka topic and
publish to another kafka topic which is in its own kafka environment
running a different kafka version,. I am using FlinkKafkaConsumer010 from
this dependency
*"org.apache.flink" %% "flink-connector-kafka-0.10" % fli
