flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai" <tzuli...@apache.org>
Subject Re: FlinkKafkaConsumer010 - Memory Issue
Date Wed, 26 Jul 2017 02:53:43 GMT

I couldn’t seem to reproduce this.

Taking another look at your description, one thing I spotted was that your Kafka broker installation
versions are, while the Kafka consumer uses Kafka clients of version (by
default, as shown in your logs).
I’m wondering whether or not that could be the root cause here.


On 26 July 2017 at 12:14:02 AM, PedroMrChaves (pedro.mr.chaves@gmail.com) wrote:

My Flink version: 1.2.1 
Kafka consumer: 010 
Kafka version: 2_11_0.10.1.0-2
View raw message