zoukankan      html  css  js  c++  java
  • 大数据技术之Kafka是什么


    Kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。

    这种动作(网页浏览,搜索和其他用户的行动)是在现代网络上的许多社会功能的一个关键因素。
    这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。 对于像Hadoop的一样的日志数据和离线分析系统,但又要求实时处理的限制,
    这是一个可行的解决方案。
    Kafka的目的是通过Hadoop的并行加载机制来统一线上和离线的消息处理,也是为了通过集群机来提供实时的消费。


    1 Kafka相关术语介绍

    Kafka 是一种高吞吐量 的分布式发布订阅消息系统,有如下特性:

        通过O(1)的磁盘数据结构提供消息的持久化,这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。
        高吞吐量[2]  :即使是非常普通的硬件Kafka也可以支持每秒数百万[2]  的消息。
        支持通过Kafka服务器和消费机集群来分区消息。
        支持Hadoop并行数据加载。

    Kafka相关术语介绍

    Broker
        Kafka集群包含一个或多个服务器,这种服务器被称为broker[5] 

    Topic

        每条发布到Kafka集群的消息都有一个类别,这个类别被称为Topic。(物理上不同Topic的消息分开存储,逻辑上一个Topic的消息虽然保存于一个或多个broker上但用户只需指定消息的Topic即可生产或消费数据而不必关心数据存于何处) 

    Partition

        Partition是物理上的概念,每个Topic包含一个或多个Partition.

    Producer

        负责发布消息到Kafka broker

    Consumer

        消息消费者,向Kafka broker读取消息的客户端。
    Consumer Group
        每个Consumer属于一个特定的Consumer Group(可为每个Consumer指定group name,若不指定group name则属于默认的group)。

  • 相关阅读:
    JDBC编程
    解决eclipse的source not found change at.
    Python 学习笔记
    网络编程(二) 多线程
    wpf 如何设置滚动条在超出范围的时候才显示?(转)
    WPF datagrid 如何隔行变色
    如果DataGrid的checkbox出现点一个另外自动点另一个现象
    WPF之DataGrid应用(转)
    WPF qq界面(转)
    SQL中distinct的用法(转)
  • 原文地址:https://www.cnblogs.com/TendToBigData/p/10501494.html
Copyright © 2011-2022 走看看