zoukankan      html  css  js  c++  java
  • Kafka集群---分布式消息系统

    概念:

      kafka是一种消息中间件

    作用:

      解耦、冗余、提高扩展性、缓冲

      保证顺序、灵活、削峰填谷

      异步通信

    kafla角色

      producer:   生产者,负责发布消息

      consumer:  消费者,负责读取处理消息

      topic:     消息的类别

      Partition:   每个Topic包含一个或多个Partition

      Broker:    Kafka集群包含一个或复哦歌服务器

    ** Kafka通过Zookeeper管理集群配置,选举Leader

    源码安装  /usr/local/kafka/config

    修改配置文件 vim server.properties

    broker.id=22
    zookeeper.connect=node1:2181,node2:2181,node3:2181

    拷贝 kafka 到其他主机,并修改 broker.id ,不能重复

     
    rsync -aSH --delete /usr/local/kafka node1:/usr/local/

    启动集群(所有节点)

    /usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties 

    验证配置,传件一个topic

    /usr/local/kafka/bin/kafka-topics.sh --create --partitions 1 --replication-factor 1 --zookeeper node3:2181 --topic aa 

    模拟生产者,发布消息

    /usr/local/kafka/bin/kafka-console-producer.sh --broker-list node2:9092 --topic aa        //写一个数据

    模拟消费者,接收消息

    /usr/local/kafka/bin/kafka-console-consumer.sh --bootstrap-server node1:9092 --topic aa
  • 相关阅读:
    datalist标签
    meter标签
    audio标签
    video标签
    time标签
    figure标签
    正则收集
    js文字无缝滚动
    页面滚动到指定位置
    Css公共文件结构
  • 原文地址:https://www.cnblogs.com/ray-mmss/p/10460821.html
Copyright © 2011-2022 走看看