我试图将kafka主题中的json数据构造成可查询的presto表。我听到一个错误说,
com.facebook.presto.spi.PrestoException: end offset 8 for column 'kafka_key' must be less that or equal to value length 0
在服务器日志文件中。将描述中的隐藏字段设置为true时,presto服务器启动,但将其设置为false时不会启动。
为什么Kafka的内部密钥没有被Map?为什么偏移量是8而不是0?
谢谢您。
暂无答案!
目前还没有任何答案,快来回答吧!