Re: kafka consumer parallelism

2017-10-05 Thread r. r.
Thanks a lot, Carst! I hadn't realized that Best regards > Оригинално писмо >От: Carst Tankink ctank...@bol.com >Относно: Re: kafka consumer parallelism >До: "r. r." <rob...@abv.bg> >Изпратено на: 05.10.2017 09:04 > Hi, >

Re: kafka consumer parallelism

2017-10-05 Thread Carst Tankink
nagers' slots anyway? Or is the map() spread out only if I do as you suggest messageStream.rebalance().map(..) ? Best regards Rob > Оригинално писмо >От: Carst Tankink ctank...@bol.com >Относно: R

Re: kafka consumer parallelism

2017-10-04 Thread r. r.
gest messageStream.rebalance().map(..) ? Best regards Rob > Оригинално писмо >От: Carst Tankink ctank...@bol.com >Относно: Re: kafka consumer parallelism >До: "user@flink.apache.org" <user@flink.apache.org> >Изпратено на: 03.10.2

Re: kafka consumer parallelism

2017-10-03 Thread Carst Tankink
ns 5 --topic fix --zookeeper 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 Ka

RE: kafka consumer parallelism

2017-10-03 Thread Sofer, Tovi
- 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 also

Re: kafka consumer parallelism

2017-10-02 Thread Timo Walther
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"