-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
1 changed file
with
71 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,71 @@ | ||
--- | ||
layout: post | ||
title: mac安装kafka | ||
author: sincat | ||
date: 2018-07-20 18:00:15 +0800 | ||
category: 技术 | ||
tags: mac kafka | ||
|
||
published: true | ||
--- | ||
|
||
## 安装使用kafka ## | ||
|
||
Step 1: Download the code | ||
|
||
>tar -xzf kafka_2.12-1.1.0.tgz | ||
>cd kafka_2.12-1.1.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. | ||
|
||
|
||
|
||
|