Hi Neeraj, I have a couple of questions, are you trying to adjust the partition assignment of records consumed by streams? In that case, you can assign a custom partition assignor for the producer sending records to the topic feeding the streams application. If you are trying to do custom partition assignments for the topics streams is *producing to *then you can provide a custom StreamPartitioner like so stream.to(topicName, Produced.with(keySerde, valueSerde).withStreamPartitiioner(YourCustomStreamPartitioner)
Does this help? -Bill On Wed, Apr 10, 2019 at 7:15 AM Neeraj Bhatt <[email protected]> wrote: > 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 change the partition assignor > > Thanks >
