热门关键字:
jquery > jquery教程 > jquery教程 > 介绍Kafka相关概念

介绍Kafka相关概念

366
作者:管理员
发布时间:2021/5/14 17:30:48
评论数:0
转载请自觉注明原文:http://www.jq-school.com/Show.aspx?id=4714
  1. Broker


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


  2. Topic


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


  3. Partition


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


  4. Producer


  负责发布消息到Kafka broker


  5. Consumer


  消息消费者,向Kafka broker读取消息的客户端。


  6. Consumer Group


  每个Consumer属于一个特定的Consumer Group(可为每个Consumer指定group name,若不指定group name则属于默认的group)


  接下来在Ubuntu系统环境下测试简单的实例。Mac系统请自己按照安装的位置,切换到相应的指令。按顺序执行如下命令:


  进入kafka所在的目录


  输入该命令


  命令执行后不会返回Shell命令输入状态,zookeeper就会按照默认的配置文件启动服务,请千万不要关闭当前终端。启动新的终端,输入如下命令:


  kafka服务端就启动了,请千万不要关闭当前终端。启动另外一个终端,输入如下命令(测试):


  注意上面的步骤顺序缺一不可:初学者,千万要记住,先启动zookeeper,再启动kafka,这个很重要,不然会出错,切记!!!


  topic是发布消息发布的category,以单节点的配置创建了一个叫dblab的topic.可以用list列出所有创建的topics,来查看刚才创建的主题是否存在。


  可以在结果中查看到dblab这个topic存在


  接下来用producer生产点数据:


  并尝试输入如下信息:


  然后再次开启新的终端或者直接按CTRL+C退出。然后使用consumer来接收数据,输入如下命令:


  便可以看到刚才产生的信息。说明kafka安装成功!!!




如果您觉得本文的内容对您的学习有所帮助:支付鼓励



关键字:50个Jquery使用技巧让你成为前端大神(四)
友荐云推荐