Kafka - java 客户端比较



我想在我的Java程序中使用Kafka。哪个 kafka Java 客户端最适合哪个用例?你能指出Kafka Streams,Kafka Connect和Kafka Spring(以及其他,如果它们存在的话(之间的区别吗?

对于简单的用例,我会使用 Kafka 发行版中的标准 Kafka 客户端:Kafka Producer 和 Kafka Consumer。编写简单的应用程序就足够了。

如果你想在Kafka之上构建复杂的流处理应用程序,Kafka Streams库是最好的选择。使用Kafka Streams,您将能够构建类似于Spark Streaming的非常复杂的应用程序(具有过滤器,地图,flatMap等功能(。

Kafka Connect 是一种将数据导入/导出到 Kafka 或从 Kafka 导出数据的方法。例如,使用 Kafka ElasticSearch-Connector,您将能够直接实时将数据从 Kafka 主题导出到 ElasticSearch。

  1. 夫卡连接:https://www.confluent.io/product/connectors/x
  2. 夫卡流:https://kafka.apache.org/documentation/streams/
  3. 夫卡客户: https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients/0.11.0.0

最新更新