Thanks a lot, Carst!
I hadn't realized that
Best regards
> Оригинално писмо
>От: Carst Tankink ctank...@bol.com
>Относно: Re: kafka consumer parallelism
>До: "r. r."
>Изпратено на: 05.10.2017 09:04
> Hi,
>
> Th
is the map() spread out only if I do as you suggest
messageStream.rebalance().map(..) ?
Best regards
Rob
> Оригинално писмо
>От: Carst Tankink ctank...@bol.com
>Относно: Re: kafka consumer
as you suggest
messageStream.rebalance().map(..) ?
Best regards
Rob
> Оригинално писмо
>От: Carst Tankink ctank...@bol.com
>Относно: Re: kafka consumer parallelism
>До: "user@flink.apache.org"
>Изпратено на: 03.10.2017 11:30
> (Acciden
localhost:2181
Regards,
Tovi
-Original Message-
From: Timo Walther [mailto:twal...@apache.org]
Sent: יום ב 02 אוקטובר 2017 20:59
To: user@flink.apache.org
Subject: Re: kafka consumer parallelism
Hi,
I'm not a Kafka expert but I th
-
From: Timo Walther [mailto:twal...@apache.org]
Sent: יום ב 02 אוקטובר 2017 20:59
To: user@flink.apache.org
Subject: Re: kafka consumer parallelism
Hi,
I'm not a Kafka expert but I think you need to have more than 1 Kafka partition
to process multiple documents at the same time. Make
Hi,
I'm not a Kafka expert but I think you need to have more than 1 Kafka
partition to process multiple documents at the same time. Make also sure
to send the documents to different partitions.
Regards,
Timo
Am 10/2/17 um 6:46 PM schrieb r. r.:
Hello
I'm running a job with "flink run -p5"
Hello
I'm running a job with "flink run -p5" and additionally set
env.setParallelism(5).
The source of the stream is Kafka, the job uses FlinkKafkaConsumer010.
In Flink UI though I notice that if I send 3 documents to Kafka, only one
'instance' of the consumer seems to receive Kafka's record and
