linux安装启动下载kafuka1.kafka,并在安装tar-xzvf kafka _ 2.13-2.4.0.tgz2. Kafka配置文件Kafka安装目录下配置文件
# theidofthebroker.thismustbesettoauniqueintegerforeachbroker.id=0#在外部端口上安装监听器=plaintext 3360///可以连接0.0的外部代理地址advertised.listeners=plaintext ://192.168.9.8433609092 #日志文件log.dirs=/tmp/Kafka zookeeper地址最大延迟zookeeper.connection.time out.ms=6000002 .嵌入式zookeeper和kafka //后台启动zookeeeper/jxdhf/zookeeee Kafka-server-start.sh-daemon config/server.properties3. topic//创建./jxdhf/Kafka-topics.sh---create---- zookeeper localhost :2181----复制- factor1----partitions1--tttt 查看。使用Kafka-topics.sh---list---- zookeeper localhost :21814.Kafka的console-producer在test1上生产新闻和更新
./jxdhf/Kafka-console-producer.sh-- broker-list localhost 33609092-- topic test1 .在Kafka的console-consumer中打开工具
./jxdhf/Kafka-console-consumer.sh-- bootstrap-server localhost 33609092-- topic test1-- from-beginning