我正在按照链接http://www.confluent.io/blog/how-to-build-a-scalable-etl-pipeline-with-kafka-connect中给出的步骤在具有 HDP2 的 EC2 上安装 kafka -connect .3 平台。
但我收到错误： 错误无法刷新 WorkerSourceTask{id=test-mysql-jdbc-0}，在等待生产者刷新未完成的消息时超时，还剩 1 个
完整的错误可以在下面看到： 图像
这是kafka 问题还是HDP 问题？因为我在AWS EMR上做了同样的事情并且它有效。