Не удается получить данные из Кафки в распределенную таблицу

На основе другого вопроса о переполнении стека вы можете выполнить:

public class MySerilizedObject
{
    [XmlIgnore]
    public bool BadBoolField { get; set; }

    [XmlElement("BadBoolField")]
    public string BadBoolFieldSerialize
    {
        get { return this.BadBoolField ? "True" : "False"; }
        set
        {
            if(value.Equals("True"))
                this.BadBoolField = true;
            else if(value.Equals("False"))
                this.BadBoolField = false;
            else
                this.BadBoolField = XmlConvert.ToBoolean(value);
        }
    }
}

0
задан Keyzj 23 February 2019 в 19:36
поделиться

1 ответ

Проблема была на моей стороне: недопустимые столбцы в материализованном представлении «потребитель». Кстати, если кому-то потребуется выполнить ту же задачу, вот карта данных:

  1. Создание «локальных» таблиц на всех хостах кластера;
  2. Создание распределенных таблиц на всех хостах кластера;
  3. Создание таблицы механизма Kafka «очередь» + материализованное представление «потребитель» на одном хосте
0
ответ дан Keyzj 23 February 2019 в 19:36
поделиться
Другие вопросы по тегам:

Похожие вопросы: