How to deploy Kafka server - Tuong-Nguyen/Angular-D3-Cometd GitHub Wiki

Installing the Default JRE/JDK

  • The easiest option for installing Java is using the version packaged with Ubuntu. Specifically, this will install OpenJDK 8, the latest and recommended version.
   $ sudo apt-get update
  • Next, install Java. Specifically, this command will install the Java Runtime Environment (JRE).
  $ sudo apt-get install default-jre
  • There is another default Java installation called the JDK (Java Development Kit). The JDK is usually only needed if you are going to compile Java programs or if the software that will use Java specifically requires it.
  • The JDK does contain the JRE, so there are no disadvantages if you install the JDK instead of the JRE, except for the larger file size.
  • You can install the JDK with the following command:
 $ sudo apt-get install default-jdk

Deploy Kafka server

  • Step 1: Download the code

    Download the 0.10.2.0 release and un-tar it.

    tar -xzf kafka_2.11-0.10.2.0.tgz cd kafka_2.11-0.10.2.0

  • Step 2: Start the server

    Kafka uses ZooKeeper so you need to first start a ZooKeeper server if you don't already have one. You can use the convenience script packaged with kafka to get a quick-and-dirty single-node ZooKeeper instance.

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

   [2013-04-22 15:01:37,495] INFO Reading configuration from: config/zookeeper.properties  
   (org.apache.zookeeper.server.quorum.QuorumPeerConfig)
   ...

Now start the Kafka server:

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

   [2013-04-22 15:01:47,028] INFO Verifying properties (kafka.utils.VerifiableProperties)  
   [2013-04-22 15:01:47,051] INFO Property socket.send.buffer.bytes is overridden to 1048576  
   (kafka.utils.VerifiableProperties)  
   ...

  • Step 3: Create a topic

    Let's create a topic named "test" with a single partition and only one replica:

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

    We can now see that topic if we run the list topic command:

    bin/kafka-topics.sh --list --zookeeper localhost:2181

   test

Alternatively, instead of manually creating topics you can also configure your brokers to auto-create topics when a non-existent topic is published to.

  • Step 4: Send some messages

    Kafka comes with a command line client that will take input from a file or from standard input and send it out as messages to the Kafka cluster. By default, each line will be sent as a separate message.

    Run the producer and then type a few messages into the console to send to the server.

    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

  This is a message
  This is another message

  • Step 5: Start a consumer

    Kafka also has a command line consumer that will dump out messages to standard output.

    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

   This is a message
   This is another message

If you have each of the above commands running in a different terminal then you should now be able to type messages into the producer terminal and see them appear in the consumer terminal.

All of the command line tools have additional options; running the command with no arguments will display usage information documenting them in more detail.

References