You might need to pipe the data through a topic with 10 partitions using
an explicit call to `.through()`

-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​
>>>
>>
>>
> 
> 

Attachment: signature.asc
Description: OpenPGP digital signature

Reply via email to