我使用Flink将数据从源发送到接收器。我的Flink应用程序使用Kafka的数据并发送到目的地。目的地也是Kafka主题，但主题名称不同。Flink仅用于交付目的，没有任何业务逻辑。
在这种情况下，我认为将flink更改为Kafka Stream将增加吞吐量。因为flink除了将数据从源传送到接收器之外没有任何贡献。而且我的源和接收器使用Kafka，所以我认为Kafka流在传送数据的情况下会更快。
如果你能对我的问题给予意见，我将不胜感激。
谢谢。
我使用Flink将数据从源发送到接收器。我的Flink应用程序使用Kafka的数据并发送到目的地。目的地也是Kafka主题，但主题名称不同。Flink仅用于交付目的，没有任何业务逻辑。
在这种情况下，我认为将flink更改为Kafka Stream将增加吞吐量。因为flink除了将数据从源传送到接收器之外没有任何贡献。而且我的源和接收器使用Kafka，所以我认为Kafka流在传送数据的情况下会更快。
如果你能对我的问题给予意见，我将不胜感激。
谢谢。
1条答案
按热度按时间tv6aics11#
不能保证一个比另一个快，你仍然需要做JVM和网络调优。
两者都可以，但Kafka Streams的限制是数据必须保留在同一个Kafka集群中，而Flink没有这样的限制。
或者您可以简单地使用MirrorMaker在不同集群的Kafka主题之间移动数据。