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

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 chang