Стратегия разделения в Кафке Стрим

Question

Какую стратегию разделения использует поток Kafka?Можем ли мы изменить стратегию разделения в Kafka Stream, как мы можем изменить в обычном Kafka Consumer

streamsConfiguration.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG,Collections.singletonList(StickyAssignor.class));

не имеет значения, и всегда используется StreamsPartitionAssignor

Answer 1

Нет.Вы не можете установить присваиватель разделов.

Kafka Streams предъявляет очень особые требования к тому, как работает назначение разделов, и, если оно выполнено неправильно, может быть вычислен неверный результат.Таким образом, не разрешается устанавливать пользовательский разделитель разделов.