zoukankan      html  css  js  c++  java
  • Kafka 安装配置 及 简单实验记录

    1. 下载二进制文件并解压,并修改 broker.id 的值

    wget http://apache.fayea.com/kafka/0.10.0.0/kafka_2.10-0.10.0.0.tgz
    tar -xzf kafka_2.10-0.10.0.0.tgz
    cd kafka_2.10-0.10.0.0
    
    # 修改 config/server.properties 中的 broker.id 的值,由于是 localhost 模式,故把 kafka 的节点数设为 1,即 broker.id=1

    2. 开启zookeeper server 和 kafka server

    bin/zookeeper-server-start.sh config/zookeeper.properties
    bin/kafka-server-start.sh config/server.properties

    注意:后台启动可以用nohup,比如:
    nohup bin/zookeeper-server-start.sh config/zookeeper.properties > myout.file 2>&1 &

    3. 创建一个topic 然后 查看创建的topic,之后不需要重复创建

    bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
    bin/kafka-topics.sh --list --zookeeper localhost:2181

    4. 发送一些message

    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
    
    #然后发送一些消息:
    This is a message
    This is another message

    5. 启动一个consumer

    bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
    
    #然后控制台会输出下面的消息
    This is a message
    This is another message
  • 相关阅读:
    JArray
    签名和验签
    private、protected、public和internal的区别
    DataTime.Now.Ticks
    NameValuePair 简单名称值对节点类型
    01安卓目录结构
    SDK目录结构
    java wait和notify及 synchronized sleep 总结
    安卓常用的第三方框架
    OkHttp使用教程
  • 原文地址:https://www.cnblogs.com/lasclocker/p/5689195.html
Copyright © 2011-2022 走看看