阿帕奇·卡夫卡|简介

Apache Kafka是一个发布-订阅消息传递系统。消息传递系统允许您在进程、应用程序和服务器之间发送消息。从广义上讲,Apache Kafka是一种可以定义和进一步处理主题(主题可能是一个类别)的软件。应用程序可以连接到此系统并将消息传输到主题上。一条消息可以包含任何类型的信息,来自你个人博客上的任何事件,也可以是一条会触发任何其他事件的非常简单的文本消息。

null

卡夫卡经纪人

卡夫卡集群通常由一个或多个服务器(称为卡夫卡代理)组成,这些服务器在其上运行卡夫卡。 制片人 是将数据(通过触发器推送消息)发布到指定代理中的Kafka主题的进程。主题消费者从卡夫卡主题中提取信息。

Cluster

卡夫卡主题: 主题基本上是一个类别或提要名称,在操作过程中存储和发布消息。消息主要是字节数组,可以以任何格式存储任何对象。是的,这是卡夫卡最棒的地方。任何对象都可以存储为字节数组。此外,正如我们之前所讨论的,所有卡夫卡的信息都被组织成主题。如果你想发送一条消息,你就把它发送到一个特定的主题,如果你想阅读一条消息,你就从一个特定的主题阅读它。 消费者和消费者群体: 消费者始终可以从特定偏移量开始读取消息,并允许从他们选择的任何偏移量点读取消息。这允许消费者在任何时间点加入集群。这使得功能和工作非常顺利。 分区允许您通过在多个代理中拆分特定主题中的数据来并行化主题。

Consumer

ApacheKafka和重要的服务器概念

  • 主题划分 :Kafka主题被划分为多个分区,允许您在多个代理之间分割数据。
  • 消费者群体 :消费者组包括订阅特定主题的消费者进程集。
  • 节点 :节点是Apache Kafka集群中的一台计算机。
  • 复制品: 分区的副本是分区的“备份”。副本从不读取或写入数据。它们用于防止数据丢失。
  • 制作人 :发送消息的应用程序。
  • 消费者 :接收消息的应用程序。

实时应用程序

  • 啁啾 :注册用户可以阅读和发布推文,但未注册用户只能阅读推文。Twitter使用Storm Kafka作为其流处理基础设施的一部分。
  • 领英 :Apache Kafka在LinkedIn上用于活动流数据和运营指标。Kafka消息传递系统帮助LinkedIn提供各种产品,如LinkedIn Newsfeed、LinkedIn Today在线消息消费以及Hadoop等离线分析系统。
  • 网飞公司 :Netflix是一家按需互联网流媒体的美国跨国提供商。Netflix使用卡夫卡进行实时监控和事件处理。
  • :在Box,Kafka用于生产分析管道和实时监控基础设施。

工具书类 :

卡夫卡官员 维基

本文由 阿尤什·维尔玛 .如果你喜欢GeekSforgek,并想贡献自己的力量,你也可以使用 贡献极客。组织 或者把你的文章寄到contribute@geeksforgeeks.org.看到你的文章出现在Geeksforgeks主页上,并帮助其他极客。

如果您发现任何不正确的地方,或者您想分享有关上述主题的更多信息,请写下评论。

© 版权声明
THE END
喜欢就支持一下吧
点赞12 分享