0

我们正在尝试将 db2-IIDR (IBM CDC) 的数据发布到 AWS 上的 Kafka。由于以下错误,订阅失败 -

 An error occurred during the conversation with Kafka. 
    Error: org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for cdckafka-subsname-commitstream-0

在 aws 上将流从 IIDR 发布到 Kafka 是否需要执行任何先决条件?

更多细节——

-Kafka 集群在 AWS 上运行

-IIDR CDC 引擎 --> 内部部署(源和目标)

- 本地 IP 已被列入白名单,我可以 ping/telnet 端口从本地到 aws,反之亦然。

谢谢!

4

1 回答 1

1

您需要使用可以与外部客户端一起使用的侦听器来设置您的 Kafka 代理。您可以在此处查看详细信息

简单地从本地客户端 ping 到 AWS 是不够的 - 您需要使用 Kafka 客户端进行验证,例如kafkacat

于 2019-01-28T23:18:15.767 回答