为什么我们的Upsolver Kafka数据源试图连接到连接中未定义的代理/节点主机？

Question

我们有卡夫卡数据源，它有7个代理(节点)，比如node1，node2 to node7。当创建Upsolver数据源时，连接只指定node1到node5。不加node6和node7。

当Upsolver试图摄取数据时，它会得到一个超时异常，看起来它正在命中node6并得到一个超时。问题是为什么Upsolver试图连接到node6，即使node6没有包含在数据源的主机列表中？

Answer 1

向Kafka客户提供的代理列表通常只用于启动与Kafka的连接。

一旦连接完毕，Kafka集群就可以并将将客户端重定向到特定节点，以便：

• 将客户端发送到包含主题数据和要从其读取的分区的节点。
• 执行负载平衡和错误恢复

具体来说，在Upsolver中，客户端列表被传递到Kafka客户端库，后者以上述方式运行。

访问所有代理节点通常需要从Kafka读取。

有关更多信息，请参见这里