我有一个场景，我们使用fluentd代理将应用程序日志转发到kafka主题，因为kafka团队引入了kerberos身份验证和fluentd版本不支持此身份验证，所以我不能直接使用转发日志。现在我们引入了一个新的没有身份验证的kafka服务器，并在那里创建了一个主题，我想用kafka连接器将新服务器中这个主题的消息转发到另一个服务器中的另一个主题，想知道如何实现这一点吗？
我有一个场景，我们使用fluentd代理将应用程序日志转发到kafka主题，因为kafka团队引入了kerberos身份验证和fluentd版本不支持此身份验证，所以我不能直接使用转发日志。现在我们引入了一个新的没有身份验证的kafka服务器，并在那里创建了一个主题，我想用kafka连接器将新服务器中这个主题的消息转发到另一个服务器中的另一个主题，想知道如何实现这一点吗？
1条答案
按热度按时间erhoui1w1#
有几种不同的工具使您能够将消息从一个集群上的kafka主题流式传输到另一个集群，包括：
mirrormaker（开源，apache kafka的一部分）
confluent's replicator（商业工具，30天免费试用）
ureplicator（uber开源）
mirus（从salesforce开源）
brucke（开源）
免责声明：我为confluent工作。