canalv1.1.2使用HA模式对接kafka

您遇到的问题可能和canal server在高可用模式下无法正确切换主备节点有关。出现这种情况的原因可能是主备节点间网络通信出现问题，导致canal server无法正确获取到binlog并发送到kafka。

解决这个问题的一个方法是检查网络设置，确保主备节点之间的连接正常。另外，您可以尝试使用canal server在高可用模式下使用UDP模式进行通信，这也许能够解决您的问题。您可以参考canal server的文档了解如何设置UDP模式。

此外，还有一些其他的可能性需要排除。例如：kafka集群是否正常工作、binlog解析是否正确等。您可以针对这些可能的问题进行一一排查，并逐步解决。

1.1.2的一个已知问题，可以尝试一下1.1.3

原回答者GitHub用户agapple

可能是因为在主备切换时，canal server HA模式下使用的是不同的ip地址或者hostname，导致kafka无法正确地接收到binlog信息。可以尝试在canal server HA配置中指定固定的ip地址或者hostname来解决这个问题。另外，也可以查看canal server和kafka之间的网络连接是否正常。