我有一个场景,我们使用fluentD代理将应用程序日志转发到Kafka主题,由于Kafka团队引入了Kerberos身份验证和不支持这种身份验证的fluentD版本,我无法直接使用前向日志。现在我们引入了一个新的无需身份验证的Kafka服务器,并在那里创建了一个主题,我想使用Kafka连接器将新服务器中的这个主题的消息转发到另一个服务器中的另一个主题,想知道我怎样才能做到这一点吗?
有几种不同的工具可以使您将消息从一个集群上的Kafka主题流式传输到另一个集群,包括:
- MirrorMaker(开源,Apache Kafka的一部分(
- Confluent的Replicator(商业工具,30天免费试用(
- uReplicator(优步开源(
- Mirus(开源自Salesforce(
- 布鲁克(开源(
免责声明:我为Confluent工作