zoukankan      html  css  js  c++  java
  • canal 环境搭建 kafka Zookeeper安装(二)

    第一步 创建Zookeeper 

    下载完成后 修改 Zookeeper中的 zoo.cfg

    修改 dataDir 、dataLogDir

    集群模式

    server.1=ServerIP:2888:3888 

    第二步  创建 kafka

    检查 server.properties 是否正确

    配置端口

    listeners=PLAINTEXT://:9092

    advertised.listeners=PLAINTEXT://本机IP:9092

    第三步 启动 Zookeeper 和kafka

    建立 bat  启动Zookeeper

    cd F:DB_Brokerzookeeper-3.4.14in
    zkServer.cmd
    pause;

    建立 bat 启动 kafka

    cd F:DB_Brokerkafka_2.12-2.4.0
    .inwindowskafka-server-start.bat .configserver.properties
    pause;

    第四步  测试 kafka 是否正常

    创建 topic 

    .inwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

    创建  生产者

    .inwindowskafka-console-producer.bat --broker-list localhost:9092 --topic test   

    (输入 任意信息 )

    创建 消费者

    .inwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning  

    (是否接受正常)

    辅助类工具

    查看 Zookeeper 信息   --------------  ZooInspector

    查看kafka     -----------------    kafka tool 2

  • 相关阅读:
    Eclipse Save Action功能
    mysql优化
    数据库从RDS迁入自己服务器上问题记录
    阿里云centos6.5安装nginx
    阿里云mysql安装
    卸载wdcp面板命令
    高性能MYSQL读书笔记1
    DelayedQueue
    spring+atomikos 实现的分布式事务
    关闭Eclipse的控制台console自动跳出
  • 原文地址:https://www.cnblogs.com/shikyoh/p/12090761.html
Copyright © 2011-2022 走看看