回复：一枚核桃 发表于 2021-6-23 10:59 建议把任务拆分为两段来判断那边出问题了：一段是消费Kafka，把内容打印出来，另一段直接写入固定数据到Hive消费Kafka应该是连接bootstrap ser感谢专家，已经定位到了，是连接hive的时候报的zookeeper的错误！您说不适用jdbc做实时流写hive，但是我目前使用的是flink1.10，也就是如下FI版本：请问在该版本下，不使用JDBC写hive，还可以通过什么方式来写，是否有示例代码，感谢！

回复：一枚核桃 发表于 2021-6-23 09:14 Flink消费Kafka的Topic进行流式处理的样例如下，请参考https://github.com/huaweicloud/huaweicloud-mrs-专家您好，kafka的各类参数我是设置在代码里面，参数设置如下：Properties properties = new Properties();properties.setProperty("bootstrap.servers", kafkaBootStrapServer);properties.setProperty("group.id", kafkaGroup);properties.put("enable.auto.commit", "true");properties.put("auto.commit.interval.ms", "1000");properties.put("security.protocol","SASL_PLAINTEXT");properties.put("sasl.kerberos.service.name","kafka");properties.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");properties.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");错误中抛连接zookeeper鉴权错误，是否是需要加其他参数？