тема журнала изменений в потоках Kafka - установка или изменение разделов

Объяснение

Тема change-logs классифицируется как внутренняя, и этому есть свидетельства в следующих 2 классах (InternalTopicConfig и InternalTopicManager):

1. Исходный код класса InternalTopicConfig содержит следующий метод, который также сообщает, что количество разделов по таким внутренним темам принудительно выполняется:

   public void setNumberOfPartitions(final int numberOfPartitions) {
   if (hasEnforcedNumberOfPartitions()) {
       throw new UnsupportedOperationException("number of partitions are enforced on topic " +
                                               "" + name() + " and can't be altered.");
   ...
   

2. Встроенная документация в исходный код класса InternalTopicManager четко заявляет об этом для makeReady() метода.

   /**
   * Prepares a set of given internal topics.
   *
   * If a topic does not exist creates a new topic.
   * If a topic with the correct number of partitions exists ignores it.
   * If a topic exists already but has different number of partitions we fail and throw exception requesting user to reset the app before restarting again.
   * @return the set of topics which had to be newly created
   */
   public Set<String> makeReady(final Map<String, InternalTopicConfig> topics) 
   ...
   

Как вы можете видеть в комментариях, если такая тема существует с правильным количеством разделов, она будет проигнорирована, а если количество разделов неверно, вы увидите ошибки, и рекомендуется использовать инструмент для сброса настроек приложения.

Надеюсь это поможет!