Analytics Space : KAFKA INFO

Данные из кафки приходят к нам в датасет g1-site.KAFKA_MESSAGES в JSON-формате:
`g1-site.KAFKA_MESSAGES.kafkastream_crusino`
`g1-site.KAFKA_MESSAGES.kafkastream_hiddenjack`
`g1-site.KAFKA_MESSAGES.kafkastream_richardcasino`
`g1-site.KAFKA_MESSAGES.kafkastream_slotozen`
`g1-site.KAFKA_MESSAGES.kafkastream_staycasino`
`g1-site.KAFKA_MESSAGES.kafkastream_wantedwin`

Обработанные в табличный вид записи лежат в g1-site.KAFKA_STAGING:
g1-site.KAFKA_STAGING.balance_transaction
g1-site.KAFKA_STAGING.bonus_issue
g1-site.KAFKA_STAGING.freespin_issue
g1-site.KAFKA_STAGING.payments
g1-site.KAFKA_STAGING.user

Чистые данные без повторов находятся в таблицах g1-site.KAFKA_CLEAN:
g1-site.KAFKA_CLEAN.balance_transaction
g1-site.KAFKA_CLEAN.bonus_issue
g1-site.KAFKA_CLEAN.freespin_issue
g1-site.KAFKA_CLEAN.payments
g1-site.KAFKA_CLEAN.receive_promo_while_reg(создается из KAFKA_STAGING.user)
g1-site.KAFKA_CLEAN.email_confirmation(создается из KAFKA_STAGING.user)
g1-site.KAFKA_CLEAN.user_personal_info(создается из KAFKA_STAGING.user)