Kafka简单使用1. 单节点单broker的部署及使用2.单节点多broker3. 容错性测试

sparkle123

发布于 2018-04-26 13:30:34

6800

发布于 2018-04-26 13:30:34

文章被收录于专栏：大数据-Hadoop、Spark大数据-Hadoop、Spark

1. 单节点单broker的部署及使用

1.1.修改配置文件$KAFKA_HOME/config/server.properties的如下项：

broker.id=0
listeners
host.name
log.dirs
zookeeper.connect

1.2.启动Kafka kafka-server-start.sh 提示帮助信息：

USAGE: /home/hadoop/app/kafka_2.11-0.9.0.0/bin/kafka-server-start.sh [-daemon] server.properties [--override property=value]*

1.3.根据提示信息，正常启动Kafaka服务 kafka-server-start.sh $KAFKA_HOME/config/server.properties

1.4.创建topic：zk kafka-topics.sh --create --zookeeper hadoop:2181 --replication-factor 1 --partitions 1 --topic hello_topic

1.5.查看所有topic：zk kafka-topics.sh --list --zookeeper hadoop:2181

1.6.发送消息：broker kafka-console-producer.sh --broker-list hadoop:9092 --topic hello_topic

1.7.消费消息：zk kafka-console-consumer.sh --zookeeper hadoop:2181 --topic hello_topic --from-beginning

1.8.from-beginning的使用

查看所有topic的详细信息： kafka-topics.sh --describe --zookeeper hadoop:2181
查看指定topic的详细信息： kafka-topics.sh --describe --zookeeper hadoop:2181 --topic hello_topic

1.9.jps -m查看kafka状态，一目了然。

[fuser@hadoop bin]$ jps -m
8386 Jps -m
3237 QuorumPeerMain /home/feiyue/app/zookeeper-3.4.5-cdh5.7.0/bin/../conf/zoo.cfg
8251 ConsoleConsumer --zookeeper hadoop:2181 --topic hello-kafka-topic
8172 ConsoleProducer --broker-list hadoop:9092 --topic hello-kafka-topic
6748 Kafka /home/feiyue/app/kafka_2.11-0.9.0.0/config/server.properties

2.单节点多broker

2.1.cp三个配置文件，修改如下：

server-1.properties
    log.dirs=/home/hadoop/app/tmp/kafka-logs-1
    listeners=PLAINTEXT://:9093
    broker.id=1

server-2.properties
    log.dirs=/home/hadoop/app/tmp/kafka-logs-2
    listeners=PLAINTEXT://:9094
    broker.id=2

server-3.properties
    log.dirs=/home/hadoop/app/tmp/kafka-logs-3
    listeners=PLAINTEXT://:9095
    broker.id=3

2.2.启动各个broker：

kafka-server-start.sh -daemon $KAFKA_HOME/config/server-1.properties &
kafka-server-start.sh -daemon $KAFKA_HOME/config/server-2.properties &
kafka-server-start.sh -daemon $KAFKA_HOME/config/server-3.properties &

2.3.jps查看

$ jps -m
3237 QuorumPeerMain /home/feiyue/app/zookeeper-3.4.5-cdh5.7.0/bin/../conf/zoo.cfg
9621 Jps -m
9462 Kafka /home/feiyue/app/kafka_2.11-0.9.0.0/config/server-1.properties
9463 Kafka /home/feiyue/app/kafka_2.11-0.9.0.0/config/server-2.properties
9499 Kafka /home/feiyue/app/kafka_2.11-0.9.0.0/config/server-3.properties

2.4.创建topic： kafka-topics.sh --create --zookeeper hadoop:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic 2.5.向多个broker生产topic kafka-console-producer.sh --broker-list hadoop:9093,hadoop:9094,hadoop:9095 --topic my-replicated-topic 2.6.消费topic kafka-console-consumer.sh --zookeeper hadoop:2181 --topic my-replicated-topic 2.7.查看有几个topic

$ kafka-topics.sh --list --zookeeper hadoop:2181
hello-kafaka-topic - marked for deletion
hello-kafka-topic
my-replicated-topic

2.8.查看topic的详情kafka-topics.sh --describe --zookeeper hadoop:2181 --topic my-replicated-topic 2.9.控制台输出：

Topic:my-replicated-topic   PartitionCount:1    ReplicationFactor:3 Configs:
    Topic: my-replicated-topic  Partition: 0    Leader: 3   Replicas: 3,1,2 Isr: 3,1,2

3. 容错性测试

leader：3
Isr: 3,1,2   //三个broker存活

kill -9 进程号码 干掉2和3，结果： Isr: 1存活broker 1，发送的消息依然可以被收到。

参考：http://kafka.apache.org/quickstart

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2018.04.10 ，如有侵权请联系 cloudcommunity@tencent.com 删除

其他

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体分享计划，欢迎热爱写作的你一起参与！

其他

登录后参与评论

0 条评论

热度