起因:在docker內(nèi)跑kafka,可以用zookeeper看到kafka的topic,kafka在本機也很正常书幕,但是在docker內(nèi)無法運行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”,建議為了保險起見最好兩個都進行操作饥悴。當(dāng)然,重啟docker就得重追加一遍hosts板熊。
google不起作用,感恩公司大神察绷!