端口问题

来源：4-5 -Kafka单节点单broker的部署及使用

starkpan

2018-09-21

老师我用的是当前最新版的zookeeper和最新版的kafka
zookeeper-3.4.13.tar.gz
kafka_2.12-2.0.0

kafka配置文件里已经将
listeners=PLAINTEXT://:9092注释了
另外没有了hostname与port
这些并没有在意，但是在这一节配置生产者和消费者的时候

创建一个topic
kafka-topics.sh --create --zookeeper hadoop001:2181 --replication-factor 1 --partitions 1 --topic hello_kafka

查看topic
kafka-topics.sh --list --zookeeper hadoop001:2181

发送消息
kafka-console-producer.sh --broker-list hadoop001:9092 --topic hello_kafka

消费消息
kafka-console-consumer.sh --bootstrap-server hadoop001:9092 --topic hello_kafka --from-beginning

我这里用的是纯官网语句，消费消息这里
1、不用把–bootstrap-server改为–zookeeper，我改了之后反而报错。
2、hadoop001:9092，这个端口也没有改，可以正常接收到生产者的消息。

和视频讲的有一些差异，感觉端口这里不是太明白，所以问一下老师。

写回答

1回答

Michael_PK

2018-09-22

已采纳

不同版本写法都不同，我上课的版本按照我的写法肯定是OK的，kafka高低版本很多都不兼容的。建议学习的时候严格按照我上课的版本来，因为那是我司上稳定运行的版本，部署随意选的。在学习完的基础上，自己想扩展再用其他版本去测试，自己去躺坑

Michael_PK

starkpan

一般正规公司都不会这么干的，新的不一定是最好的，稳定才是王道

2018-09-22

共3条回复

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

相似问题

回答 1

回答 1

回答 2

回答 1

回答 4