AWS 上的 IIDR CDC Kafka
IIDR CDC Kafka on AWS
我们正在尝试将数据从 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 的端口,反之亦然。
谢谢!
您需要为您的 Kafka 代理设置与外部客户端一起工作的侦听器。可以看到details here。
仅从本地客户端 ping 到 AWS 是不够的 - 您需要使用 Kafka 客户端验证它,例如 kafkacat
我们正在尝试将数据从 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 的端口,反之亦然。
谢谢!
您需要为您的 Kafka 代理设置与外部客户端一起工作的侦听器。可以看到details here。
仅从本地客户端 ping 到 AWS 是不够的 - 您需要使用 Kafka 客户端验证它,例如 kafkacat