Итак, я запускаю kafka с двумя темами, и они оба будут обслуживать файлы -
Topi c 1 - я читаю строковое значение из него и обрабатываю его. Topi c 2 - мне нужны двоичные значения для обработки.
Итак, я предполагаю, что мне понадобятся два потребителя? Причина этого заключается в том, что в свойствах для данных из первой топи c мне нужен StringSerializer / Deserializer, а для второй мне нужен десериализатор BinaryArraySerializer.
Так что возможно иметь две реализации для потребителей ?
Я знаю, что я могу получить строковое значение и преобразовать его в двоичное или наоборот, но каким-то образом наличие двух потребителей кажется чистым способом сделать это.
Заранее спасибо.