开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

是在kafka集群的server.prope配置还是在kafka消费者的配置信息里 加入这个配置?

大佬们,在看帖子有说 Kafka的 隔离级别默认是 isolation.level 是 read_uncommitted,想修改成read_committed,该怎么配置? 是在kafka集群的server.properties配置文件里配置吗?还是在kafka消费者的配置信息里 加入这个配置就行?

展开
收起
圆葱猪肉包 2023-03-27 14:15:25 258 0
2 条回答
写回答
取消 提交回答
  • 在消费者配置信息配置就行 此回答整理自钉群“【③群】Apache Flink China社区”

    2023-03-28 11:06:18
    赞同 展开评论 打赏
  • 发表文章、提出问题、分享经验、结交志同道合的朋友

    1、在Kafka消费者的配置信息中添加以下配置(只对该消费者有效)

    props.put("isolation.level", "read_committed");
    

    2、在server.properties中设置以下属性

    isolation.level = read_committed
    
    

    注意,修改server.properties的隔离级别可能会影响到所有使用该Kafka Broker的消费者。

    2023-03-27 17:32:48
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载