Невозможно прочитать тему кафки из Drill - PullRequest
Новая
       47

Невозможно прочитать тему кафки из Drill

1 голос
/ 05 октября 2019

Мы работаем над добавлением детализации SQLEngine - Apache поверх Kafka и включаем доступ к запросам в целях устранения неполадок.

Вот конфигурация Kafka 

{
  "type": "kafka",
  "kafkaConsumerProps": {
    "security.protocol": "SSL",
    "enable.auto.commit": "true",
    "value.deserializer": "org.apache.kafka.common.serialization.ByteArrayDeserializer",
    "group.id": "drill-consumer",
    "auto.offset.reset": "earliest",
    "ssl.truststore.location": "kafka.truststore.jks",
    "bootstrap.servers": "abc1:9911,abc2:9911,abc3:9911",
    "ssl.truststore.password": "abcdef",
    "key.deserializer": "org.apache.kafka.common.serialization.ByteArrayDeserializer"
  },
  "enabled": true
}

, к которой мы можем подключиться Kafka и читать темы 

show tables;

Однако, когда мы запрашиваем тему 

select * from kafka.testtopic limit 10;

мы получаем ниже сообщение об ошибке

org.apache.drill.common.exceptions.UserRemoteException: DATA_READ ERROR: ошибка при чтении сообщений от kafka. Записывающее устройство было записано: 1 com.google.gson.stream.MalformedJsonException: используйте JsonReader.setLenient (true) для принятия искаженного JSON в строке 1, столбец 10, фрагмент 0: 0 [идентификатор ошибки: 1728b1e7-ba2a-4750-895f-285743e05301 onимя хоста: 31010]

...