请问canal 支持kafka2.1.0版本吗？

canal.mq.dynamicTopic=.\..，这样配就可以按表创建topic并将消息发送到相应topic上， 官网文档可能有点不正确

原回答者GitHub用户finefuture

问题可能是由于 Canal Adapter for Elasticsearch 在切换到 HA 模式后，未正确配置相关参数导致的。

具体而言，错误信息中提到了 Outer adapter sync failed! Error sync but ACK! 以及 java.lang.NullPointerException，这意味着 Canal Adapter for Elasticsearch 在执行同步操作时遇到了错误，并且没有正确处理该错误。这个错误可能来自于配置文件中未正确设置的参数或者其他错误原因。

针对这个问题，您可以尝试以下解决方法：

确认 Canal Adapter for Elasticsearch 的版本是否与您使用的 Canal Server 版本兼容，并确认已经将 Canal Adapter for Elasticsearch 配置为 HA 模式。在 HA 模式下，Canal Adapter for Elasticsearch 需要正确配置相关参数，才能正常运行。建议您查阅官方文档，了解如何正确配置 HA 模式的 Canal Adapter for Elasticsearch。

确认 Canal Adapter for Elasticsearch 的同步配置是否正确。在 HA 模式下，Canal Adapter for Elasticsearch 需要正确设置数据同步的配置项，才能正常同步数据。建议您仔细检查同步配置项，并确保已经正确设置。

如果以上两种方法都无法解决问题，您可以尝试手动排除错误。根据错误信息，可以看出 Canal Adapter for Elasticsearch 在执行同步操作时发生了 NullPointerException，这可能是由于缺少必要的参数或者其他错误原因导致的。您可以通过仔细分析错误信息和日志文件，逐步排除错误，找到问题所在。