Re: Partition Strategy in Kafka Stream

2019-04-15 Thread Matthias J. Sax
his help? >> >> -Bill >> >> On Wed, Apr 10, 2019 at 7:15 AM Neeraj Bhatt >> wrote: >> >>> Hi >>> >>> Which partition strategy Kafka stream uses? Can we change the partition >>> strategy in Kafka Stream as we can change in no

Re: Partition Strategy in Kafka Stream

2019-04-10 Thread Neeraj Bhatt
> Produced.with(keySerde, > valueSerde).withStreamPartitiioner(YourCustomStreamPartitioner) > > Does this help? > > -Bill > > On Wed, Apr 10, 2019 at 7:15 AM Neeraj Bhatt > wrote: > > > Hi > > > > Which partition strategy Kafka stream uses? Can we change the

Re: Partition Strategy in Kafka Stream

2019-04-10 Thread Bill Bejeck
: > Hi > > Which partition strategy Kafka stream uses? Can we change the partition > strategy in Kafka Stream as we can change in normal Kafka Consumer > > > > streamsConfiguration.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG,Collections.singletonList(ColombiaSt

Partition Strategy in Kafka Stream

2019-04-10 Thread Neeraj Bhatt
Hi Which partition strategy Kafka stream uses? Can we change the partition strategy in Kafka Stream as we can change in normal Kafka Consumer streamsConfiguration.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG,Collections.singletonList(ColombiaStrictStickyAssignor.class)); so not