nullable(Int16),
                  
                  
                      `Cause` nullable(Int16)
                  
                  
                  kafka_format = 'JSONEachRow'
                  
                  
                  В кафке
                  
                  
                  ,"Status":"-1","Cause":"",
                  
                  
                  
                  
                  
                  Но при выборке с кафка таблички всё равно вижу, что происходит подмена Cause на 0. Не учёл какую-то системную настройку?
                  
                  
                  SELECT
                  
                  
                      date_time,
                  
                  
                      Status,
                  
                  
                      Cause
                  
                  
                  FROM Test_kafka
                  
                  
                  ORDER BY date_time DESC
                  
                  
                  LIMIT 10
                  
                  
                  
                  
                  
                  Query id: d165ea9c-db66-402c-9eb2-5c3e00ddc5cd
                  
                  
                  
                  
                  
                  ┌───────────date_time─┬─Status─┬─Cause─┐
                  
                  
                  │ 2021-10-29 14:43:54 │     -1 │     0 │
                  
                  
                
попробуйте Nullable с большой буквы
--input_format_null_as_default arg For text input formats initialize null fields with default values if data type of this field is not nullable
Но у меня же как раз указан data type is nullable, разве нет? CREATE TABLE statistics.test_null_kafka ( `Status` Nullable(Int16), `Cause` Nullable(Int16) ) ENGINE = Kafka SETTINGS kafka_broker_list = '172.26.17.61:9092', kafka_topic_list = 'test_null_kafka', kafka_group_name = 'clickhouse_prod_71', kafka_format = 'JSONEachRow'; [root@Mon-01 kafka]# ./kafka-tldl.sh read test_null_kafka {"Status":"-1","Cause":""} localhost :) select * from test_null_kafka; SELECT * FROM test_null_kafka Query id: eece2c04-3b39-4405-a71b-a316c7561595 ┌─Status─┬─Cause─┐ │ -1 │ 0 │ └────────┴───────┘
Обсуждают сегодня