kafka-streams 2.5.0 не поддерживает Named on reduce?

Question

Привет, мне нужно дать собственное имя внутренним / промежуточным темам, созданным в kafka-streams.

Однако переименовываются только темы «* с перераспределением», а « агрегат»"не переименовываются.

Похоже, что kafka-streams 2.5.0 не поддерживает Named on reduce?

Я настроил, но он не принимает .. сгруппированные берут именованные и видят повторно разбитые на разделы темы с этим именем, но сокращенные не принимают это имя.

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

Обновление: Привет, сообщество кафков, я понимаю, аргумент Named, который я использовал, используется для конфигурации, используемой для присвоения имени процессору в топологии, но есть ли способ дать пользовательское, более читаемое имя промежуточному топу c как kstream-aggregate -...? Спасибо

Answer 1

Должна быть возможность именовать все процессоры / магазины / темы.

Однако не всегда понятно, как работает API - на самом деле, некоторые Named параметры «перекрываются». Это известная проблема, и она плохо документирована. В какой-то момент нам нужно исправить это.

Если вы хотите назвать журнал изменений topi c, вы можете назвать соответствующее хранилище через Materialized, и имя магазина будет повторно использовано для журнала изменений topi c.

Если вы хотите назвать топ повторного разбиения c, вы можете передать имя через параметр Grouped в groupBy() или groupByKey().