Я читаю о потоках kafka для потенциального использования в моем приложении. Я использую безопасный брокер Kafka (версия 2.5.0, SSL Security), и мое потоковое приложение будет иметь доступ только для чтения. Тот факт, что потоки kafka используют координацию на стороне сервера, очень полезен в моем сценарии, поскольку потокам задач Stream не нужно взаимодействовать друг с другом.
Согласно документации, потокам kafka требуется разрешение на создание topi c для создать несколько внутренних тем (журнал изменений и повторное разделение) и записать в них разрешения. В качестве альтернативы, эти темы можно создать заранее, чтобы не давать разрешения на создание topi c. Журнал изменений topi c используется для хранилища состояний, и если вы выполняете агрегирование и перераспределение, topi c используется, если вы начинаете преобразовывать ключ вашего потока.
Мой вопрос, если я уверен, что я не с использованием хранилища состояний / агрегации / переразбивки. будет ли решение на основе потоков Kafka работать, если я не предоставлю разрешения на запись приложению потоков? Будет ли координация на стороне сервера работать безупречно?