我们正在努力添加一个 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:数据读取错误：从kafka读取消息时失败。recordreader位于记录：1 com.google.gson.stream.malformedjsonexception:使用jsonreader.setlenient（true）接受第1行第10列片段0:0处的格式错误的json[错误id:1728b1e7-ba2a-4750-895f-285743e05301 on]hostname:31010]