You might need to pipe the data through a topic with 10 partitions using an explicit call to `.through()`
Advertising
-Matthias On 4/11/18 12:48 AM, Shivam Sharma wrote: > No I am not repartitioning data later. But I wanted to run 10 applications. > Is there any way to do this? > > On Mon, Apr 9, 2018 at 1:44 AM, Matthias J. Sax <matth...@confluent.io> > wrote: > >> It depend on the concrete program you write... Most likely it's 4, but >> hard to say without more information. >> >> If you read all 4 topics as a single stream (i.e. pattern subscription) >> it should be 4. If you repartitions data in your applications later, it >> might be more thought. >> >> >> -Matthias >> >> >> On 4/8/18 11:23 AM, Shivam Sharma wrote: >>> Hi, >>> >>> Lets say I have one consumer group which subscribed to *4 topics* and >>> partitions for each topics are:- >>> >>> 1. First topic => 4 partitions >>> 2. Second topic => 3 partitions >>> 3. Third topic => 2 partitions >>> 4. Fourth topic => 1 partitions >>> >>> Total number of *partitions = 10*. So total how many applications I can >> run >>> simultaneously. >>> >>> 4 or 10? >>> Thanks >>> >> >> > >
signature.asc
Description: OpenPGP digital signature
