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

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

展开

收起

圆葱猪肉包 2023-03-27 14:15:25 279 版权

2 条回答

写回答

取消提交回答

我是三好学生

在消费者配置信息配置就行此回答整理自钉群“【③群】Apache Flink China社区”

2023-03-28 11:06:18

赞同展开评论
凌云Cloud

发表文章、提出问题、分享经验、结交志同道合的朋友
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

赞同展开评论

问答分类：

消息中间件 Kafka 云消息队列 Kafka 版

问答标签：

云消息队列 Kafka 版消费者云消息队列 Kafka 版集群云消息队列 Kafka 版配置云消息队列 Kafka 版信息云消息队列 Kafka 版配置消费者

问答地址：

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

相关问答

实时计算 Flink版

flink 1.15x kafka pom是不是只需要配置这个就行了？

138

给一个使用Java实现的Kafka消费者示例代码？

140

大数据计算MaxCompute在odps上有一个kafka同步到es的离线任务任务是这么配置的？

在Confluent集群中如何新建一个名为pv-uv的Topic，并设置其分区数为3？

如何在Confluent集群中创建一个新的消息队列（Topic）？

DataWorks在odps上有一个kafka同步到es的离线任务任务是这么配置的？

在Flink CDC中，导致输出到kafka的数据错误是哪里配置问题吗？

有大佬知道这是怎么回事么 flink读不到kafka数据

1199

请问下当flink集群重启之后 kafka消息还是重复有什么办法解决吗 kafka sink 已设

1176

麻烦问一下，我们现在的架构是希望数据统一从 Kafka 中出，但是又想用 Flink CDC，请问

1109

大数据与机器学习

实时计算 Flink

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

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。