docker内kafka异常:ERROR Failed to flush WorkerSourceTask{id=}, timed out while waiting for producer to flush outstanding messages,

起因:在docker内跑kafka,可以用zookeeper看到kafka的topic,kafka在本机也很正常,但是在docker内无法运行producer和consumer.
Error:

ERROR Failed to flush WorkerSourceTask{id=local-file-source-0}, timed out while waiting for producer to flush outstanding messages, 1 left

ERROR Failed to commit offsets for WorkerSourceTask

解决方案:
kafka的conf/server.properties中有部分advertised.listeners=PLAINTEXT://your.host.name:9092,这个地方表示把hostname注册到zookeeper里,但是docker并不识别你的hostname.所以,可以把此处的your.host.name改成你的ip地址或者在docker的etc/hosts下追加上你的ip映射进行DNS解析,比如“10.12.23.68 hostname”,建议为了保险起见最好两个都进行操作。当然,重启docker就得重追加一遍hosts。

google不起作用,感恩公司大神!

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,328评论 19 139
  • 前言 文章主要介绍以docker容器的方式部署kafka集群。 环境说明 三台虚拟机:centos7.2 dock...
    汤尼房阅读 14,272评论 0 11
  • ** 今天看了一下kafka官网,尝试着在自己电脑上安装和配置,然后学一下官方document。** Introd...
    RainChang阅读 10,436评论 1 30
  • 在hyperledger fabric的orderer中,目前发布的版本是使用kafka来做排序,并没有用到所谓的...
    y9g阅读 11,662评论 0 3
  • 在软件项目的生命周期中,开发只占开始的一小部分,大部分时间我们要对项目进行运行维护,Kafka相关的项目也不例外。...
    柴诗雨阅读 12,516评论 0 7