Я пытаюсь поместить большое количество сообщений (350 МБ) в тему клиента (исходную тему) с таким форматом значений, как этот
10957402000||10965746672||2|2756561822|452048703649890|8984048701003649890
, а затем создаю несколько потоков и таблиц по этой теме, ноФормат с разделителями, поддерживаемый ksql - это просто разделитель запятых.У меня есть несколько вопросов:
- Есть ли способ настроить ksql, чтобы понять мой формат?Или я должен преобразовать в формат по умолчанию с помощью ksql (разделитель запятых)
- Из исходного значения из исходного раздела, как описано выше, как эта команда может отображать значение в столбце таблицы?Или я должен конвертировать формат в JSON?CREATE STREAM (sub_id BIGINT, contract_id BIGINT, cust_id BIGINT, account_id BIGINT, telecom_service_id BIGINT, isdn BIGINT, imsi BIGINT) \ WITH (KAFKA_TOPIC = 'customer', VALUE_FORMAT = 'DELIMITED'); * 100 *
1011 *1011*вы.