报错信息:

Caused by: org.apache.kafka.common.errors.TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

原因:

Kafka集群有一台节点磁盘坏了,partition无法选主,导致flink任务无法写Kafka

解决方案:

将Kafka unclean leader参数设置为true先选举出主分片,后续修改server配置,将最小ISR数量变更为2

Timeout expired after 60000milliseconds while awaiting InitProducerId相关推荐

  1. 【Flink】Flink exactly-once 报错 Timeout expired after 60000 milliseconds while awaiting InitProducerId

    文章目录 1.概述 2.源码分析 1.概述 flink 开启了exactly-once,设置了transaction.id 然后flink一直不停重启,一直报错 org.apache.kafka.co ...

  2. 连接池和 Timeout expired异常

    转自:博客园宁静.致远:http://www.cnblogs.com/zhangzhu/archive/2013/10/10/3361197.html 异常信息: MySql.Data.MySqlCl ...

  3. MySql 长时间读数据发生超时的异常 Mysql Reader Exception TimeOut expired

    mysql connector: .net var r = cmd.ExecuteReader() r.Reader()   // <--长时间不停调用 Timeout expired.  Th ...

  4. oracle之 RA-00054: resource busy and acquire with NOWAIT specified or timeout expired

    1. truncate 表报 ORA-00054 ,标明有事务正在操作该表 SQL> truncate table alldm.DM_XQKD_YUJING_D; truncate table ...

  5. 【Kafka】Flink kafka TimeoutException Timeout expired while fetching topic metadata

    1.背景 一个服务突然不能工作了,数据有输入但是没有数据,好看数据输入进去就丢了,但是正常情况下,应该是最起码正确和错误都应该输出. 下面开始查看日志 docker exec -it xxxx bas ...

  6. 连接池和 Timeout expired异常【转】

    异常信息: MySql.Data.MySqlClient.MySqlException (0x80004005): error connecting: Timeout expired. The tim ...

  7. ConnectionRead (WrapperRead())Timeout expired

    ConnectionRead (WrapperRead())Timeout expired ■环境说明: 数据库系统:Microsoft Server 2000 (Sp4) 操作系统:Microsof ...

  8. 【Oracle】ORA-00054: resource busy and acquire with NOWAIT specified or timeout expired

    今天在修改表字段类型时出现错误:ORA-00054: resource busy and acquire with NOWAIT specified or timeout expired,看报错应该是 ...

  9. [译]连接池和 Timeout expired异常

    原文标题:Connection Pooling and the "Timeout expired" exception FAQ 来源:http://blogs.msdn.com/a ...

最新文章

  1. Spring boot、微服务、OAuth、OpenID的爱恨情仇!
  2. MemCached java client 1.5.1 性能测试
  3. 访问数组元素进行获取
  4. python中range函数是什么意思_python里range是什么
  5. 从零开始学java 框架_从零开始学 Java - 搭建 Spring MVC 框架
  6. 企业建立私有云的N个理由
  7. bada 2D游戏编程之一——图形绘制
  8. Airflow 中文文档:保护连接
  9. python数据结构剑指offer-从尾到头打印链表
  10. python多用户登录_python多用户
  11. Android Studio导入so文件到项目中
  12. 1月10日云栖精选夜读:专访金榕:四年蜕变,阿里iDST是如何登上浪潮之巅的?...
  13. Chrome无法使用Unity Web Player的解决方案
  14. 外文文献怎么找?5个免费图书馆和网站帮你下载90%的外文文献!
  15. 网卡驱动离线安装经验,避坑指南
  16. 八大排序算法(原理+代码详解)Python版
  17. 语音数字信号处理与分析及Matlab实现
  18. 什么是串行接口和并行接口
  19. 【清华大学】深入理解操作系统(陈渝) 第二章
  20. 五险一金,你真的懂吗

热门文章

  1. private访问权限java_Java中的访问权限控制
  2. MySQL数据库设计三大范式
  3. 塔望消费战略:消费时代,食品企业的本质性核心战略
  4. 从程序员角度谈谈为什么英雄联盟一区总是常常排队?
  5. C#连接OPC server失败,报错80040154 没有注册类
  6. python opencv 双击鼠标绘制圆
  7. 强化学习 reward 曲线的绘制
  8. (五)Selenium自动化测试实战—PO模式
  9. Mysql更改列名的方法
  10. 移动WiFi大比拼 谁会成为独角兽