kafka- 单节点 - 单代理配置

àì夳堔傛蜴生んèń 2022-05-19 09:08 216阅读 0赞

在此配置中，您有一个ZooKeeper和代理id实例。 以下是配置它的步骤 -  
创建Kafka主题 - Kafka提供了一个名为 kafka-topics.sh 的命令行实用程序，用于在服务器上创建主题。 打开新终端并键入以下示例。  
语法  
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic-name  
示例  
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic Hello-Kafka  
我们刚刚创建了一个名为 Hello-Kafka 的主题，其中包含一个分区和一个副本因子。 上面创建的输出将类似于以下输出 -  
输出 - 创建主题 Hello-Kafka  
创建主题后，您可以在Kafka代理终端窗口中获取通知，并在config / server.properties文件中的“/ tmp / kafka-logs /"中指定的创建主题的日志。  
主题列表

要获取Kafka服务器中的主题列表，可以使用以下命令 -  
语法  
bin/kafka-topics.sh --list --zookeeper localhost:2181  
输出  
Hello-Kafka  
由于我们已经创建了一个主题，它将仅列出 Hello-Kafka 。 假设，如果创建多个主题，您将在输出中获取主题名称。  
启动生产者以发送消息

语法  
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic topic-name  
从上面的语法，生产者命令行客户端需要两个主要参数 -  
代理列表 - 我们要发送邮件的代理列表。 在这种情况下，我们只有一个代理。 Config / server.properties文件包含代理端口ID，因为我们知道我们的代理正在侦听端口9092，因此您可以直接指定它。  
主题名称 - 以下是主题名称的示例。  
示例  
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Hello-Kafka  
生产者将等待来自stdin的输入并发布到Kafka集群。 默认情况下，每个新行都作为新消息发布，然后在 config / producer.properties 文件中指定默认生产者属性。 现在，您可以在终端中键入几行消息，如下所示。  
输出  
$ bin/kafka-console-producer.sh --broker-list localhost:9092  
\--topic Hello-Kafka\[2016-01-16 13:50:45,931\]  
WARN property topic is not valid (kafka.utils.Verifia-bleProperties)  
Hello  
My first message  
My second message  
启动消费者以接收消息

与生产者类似，在 config / consumer.proper-ties 文件中指定了缺省使用者属性。 打开一个新终端并键入以下消息消息语法。  
语法  
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic topic-name  
\--from-beginning  
示例  
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic Hello-Kafka --from-beginning

输出  
Hello  
My first message  
My second message  
最后，您可以从制作商的终端输入消息，并看到他们出现在消费者的终端。 到目前为止，您对具有单个代理的单节点群集有非常好的了解。

# 总结： #

kafka  
安装： 1.JDK 2.zookeeper 3.kafka  
配置环境变量：

\#jdk  
export JAVA\_HOME=/home/ubuntu/jdk1.8.0\_65  
export PATH=$PATH:$JAVA\_HOME/bin  
export CLASSPATH=.:$JAVA\_HOME/lib/dt.jar:$JAVA\_HOME/lib/tools.jar  
\#zookeeper  
export ZK\_HOME=/home/ubuntu/zookeeper-3.4.11  
export PATH=$PATH:$ZK\_HOME/bin  
\#kafka  
export KAFKA\_HOME=/home/ubuntu/kafka\_2.12-1.0.0  
export PATH=$PATH:$KAFKA\_HOME/bin  
  
  
启动 kafka-server-start.sh /home/ubuntu//home/ubuntu/kafka\_2.12-1.0.0/config/server.properties  
创建一个主题 topic：  
kafka-topics.sh --create --topic xxxx --zookeeper localhost:2181 --partitions 1 --replication-factor