从Apache Kafka的安装到教程完整地概括了整个过程

Apache Kafka 是什么？

Apache Kafka是由Apache软件基金会开发的开源流处理平台，使用Scala和Java语言编写。该项目旨在提供一个统一、高吞吐量、低延迟的平台，用于处理实时数据源。

Apache Kafka是由Apache软件基金会开发的开源流处理平台，使用Scala和Java编写。该项目旨在提供一个高吞吐量、低延迟的平台，用于处理实时数据流。

卡夫卡有什么用处？ shé me ?)

它被用于两个广泛的应用类别中：

构建可靠的实时流数据管道，确保数据在系统或应用之间的传输。

构建能够转换或响应数据流的实时流应用程序

通过使用Kafka

• システムまたはアプリケーション間で確実にデータを取得するリアルタイムのストリーミングデータパイプラインの構築が可能

データストリームを変換または反応するリアルタイムのストリーミングアプリケーションを構築が可能

GitHub – 吉特哈布

安装Kafka

下载代码

$ wget http://ftp.riken.jp/net/apache/kafka/0.10.2.0/kafka_2.11-0.10.2.0.tgz
$ tar -zxf kafka_2.11-0.10.2.0.tgz
$ cd kafka_2.11-0.10.2.0

安装Java。

$ yum search openjdk
$ yum install java-1.8.0-openjdk-devel

教程

使用Kafka的命令行客户端，将消息发送到Kafka集群中。

开启服务器

# start ZooKeeper server
$ bin/zookeeper-server-start.sh config/zookeeper.properties
# start Kafka server
$ bin/kafka-server-start.sh config/server.properties

创造一个话题

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

发送消息

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

在执行上述命令后，继续在控制台输入以下消息。

$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
This is a message
This is another message

接收消息（启动消费者）

打开一个与发送消息的客户端不同的客户端，并执行以下命令。

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

当然地，输入在消息发送中的消息会被接收到。

$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
This is a message
This is another message

参考文献

https://kafka.apache.org/quickstart