默认内网访问,要在外网访问的话,需要在修改config/server.properties中的配置

将listeners和advertised.listeners的值用主机名进行替换,在外用使用java进行生产者或消费者连接的时候,不填写具体的IP,填写安装kafka的主机名,然后,在hosts目录中,配置该主机名对应的真是IP地址即可;

以下命令都是摘抄与官网http://kafka.apache.org/quickstart

先启动zookeeper,默认自带的

bin/zookeeper-server-start.sh config/zookeeper.properties

然后启动kafka服务

bin/kafka-server-start.sh config/server.properties

方法一:

在bin的上一级目录执行命令:

bin/kafka-server-start.sh -daemon config/server.properties

加守护进程启动

 

方法二:

在bin的上一级目录执行命令:

nohup bin/kafka-server-start.sh config/server.properties &

通过后台来启动

 

 

 

列举拥有哪些topics

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

在服务器上打开一个生产者,然后把输入的每行数据发送到kafka中的命令

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
#后面光标提示数据数据,然后回车就会发送到kafka中了

打开一个消费者

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

当有数据往kafka的test主题发送消息,这边就会进行消费。

相关文章:

  • 2022-12-23
  • 2021-10-29
  • 2021-09-25
  • 2021-10-12
  • 2021-06-11
  • 2021-08-09
  • 2022-12-23
猜你喜欢
  • 2021-05-29
  • 2022-01-03
  • 2022-12-23
  • 2021-12-18
  • 2021-11-20
相关资源
相似解决方案