Я пытаюсь выяснить, как передать сообщения от потребителя Kafka, подписанного на несколько тем, на этап обработки, основанный на теме (например, сохранить их в определенном файле или базе данных или где-либо еще).
Существует Consumer.externalCommittableSource, но он требует ручного выбора разделов, чего я хочу избежать.
В общем, как правильно динамически создавать потоки и приемники на основе значения некоторого атрибута группировки элементов потока?