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
Hi,

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 0.10.1.0, while the Kafka consumer uses Kafka clients of version 0.10.0.1 (by
default, as shown in your logs).
I’m wondering whether or not that could be the root cause here.

Cheers,
Gordon

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
Mime
View raw message