Kafkaのインストールとテスト

5818 ワード

1、zokeeperのインストールと配置

  • zokeeperのconfディレクトリの下にzooを新規作成する.cfgファイルは、以下のように構成されている
  • # The number of milliseconds of each tick
    tickTime=2000
    # The number of ticks that the initial 
    # synchronization phase can take
    initLimit=10
    # The number of ticks that can pass between 
    # sending a request and getting an acknowledgement
    syncLimit=5
    # the directory where the snapshot is stored.
    # do not use /tmp for storage, /tmp here is just 
    # example sakes.
    dataDir=/opt/app/zookeeper-3.4.5/data
    # the port at which the clients will connect
    clientPort=2181
    #
    # Be sure to read the maintenance section of the 
    # administrator guide before turning on autopurge.
    #
    # http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance
    #
    # The number of snapshots to retain in dataDir
    #autopurge.snapRetainCount=3
    # Purge task interval in hours
    # Set to "0" to disable auto purge feature
    #autopurge.purgeInterval=1 
    
    server.1=bigdata.eclipse.com:2888:3888
    
  • zokeeperでdataディレクトリを作成し、dataディレクトリにmyidファイルを作成します.ファイルの内容は「1」
  • です.
  • zokkperサービス
  • を開始
    ## 
    bin/zkCli.sh start
    ## 
    bin/zkCli.sh status
    ## 
    bin/zkCli.sh
    ## zokeeper 
    ls /

    1、kafkaの取り付けとテスト

  • 1) Start the server
  • bin/kafka-server-start.sh config/server.properties
  • 2) Create a topic
  • bin/kafka-topics.sh --create --zookeeper bigdata.eclipse.com:2181 --replication-factor 1 --partitions 1 --topic test_topic 
    
    bin/kafka-topics.sh --list --zookeeper bigdata.eclipse.com:2181
  • 3) Send some messages
  • bin/kafka-console-producer.sh --broker-list bigdata.eclipse.com:9092 --topic test_topic
    
    This is a message
    This is another message
  • 4)Start a consumerは、複数のウィンドウを開いてメッセージを受信することができる
  • bin/kafka-console-consumer.sh --zookeeper bigdata.eclipse.com:2181 --topic test_topic --from-beginning