• kafka 3.0 离线安装


    1.安装zookeeper

     解压apache-zookeeper-3.8.0-bin.tar.gz到指定目录,复制conf目录下zoo_sample.cfg到zoo.cfg,并修改配置。

    1. # The number of milliseconds of each tick
    2. tickTime=2000
    3. # The number of ticks that the initial 
    4. # synchronization phase can take
    5. initLimit=10
    6. # The number of ticks that can pass between 
    7. # sending a request and getting an acknowledgement
    8. syncLimit=5
    9. # the directory where the snapshot is stored.
    10. # do not use /tmp for storage, /tmp here is just 
    11. # example sakes.
    12. dataDir=/data/etl/zookeeper-3.8.0-bin/data
    13. clientPort=2181
    14. maxClientCnxns=60

    进入bin目录,启动zookeeper

    ./zkServer.sh start

    2.安装Kafka

    解压kafka_2.12-3.0.0.tgz到指定目录。

    进入到config目录,修改server.properties配置

    1. # 允许外部端口连接   
    2. listeners=PLAINTEXT://0.0.0.0:9092
    3. # 外部代理地址
    4. advertised.listeners=PLAINTEXT://10.16.60.62:9092
    5. log.dirs=/data/etl/kafka_2.12-3.0.0/log
    6. zookeeper.connect=10.16.60.62:2181

    advertised.listeners才是真正的对外代理地址,listeners的作用不是对外提供服务代理,而是监听!

    启动kafka

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

    3.使用测试

    创建主题topic

    ./kafka-topics.sh --create --topic myevents --partitions 10 --replication-factor 1 --bootstrap-server localhost:9092

    查看主题

    ./kafka-topics.sh --describe --topic myevents --bootstrap-server localhost:9092    
    1. Topic: myevents TopicId: 68wbesvHSmmYSTRu-odyeQ PartitionCount: 20      ReplicationFactor: 1    Configs: segment.bytes=1073741824
    2.         Topic: myevents Partition: 0    Leader: 0       Replicas: 0     Isr: 0
    3.         Topic: myevents Partition: 1    Leader: 0       Replicas: 0     Isr: 0
    4.         Topic: myevents Partition: 2    Leader: 0       Replicas: 0     Isr: 0
    5.         Topic: myevents Partition: 3    Leader: 0       Replicas: 0     Isr: 0
    6.         Topic: myevents Partition: 4    Leader: 0       Replicas: 0     Isr: 0
    7.         Topic: myevents Partition: 5    Leader: 0       Replicas: 0     Isr: 0
    8.         Topic: myevents Partition: 6    Leader: 0       Replicas: 0     Isr: 0
    9.         Topic: myevents Partition: 7    Leader: 0       Replicas: 0     Isr: 0
    10.         Topic: myevents Partition: 8    Leader: 0       Replicas: 0     Isr: 0
    11.         Topic: myevents Partition: 9    Leader: 0       Replicas: 0     Isr: 0
    12.         Topic: myevents Partition: 10   Leader: 0       Replicas: 0     Isr: 0

    删除主题

    ./kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic myevents
    

  • 相关阅读:
    java泛型入门篇
    计算机组成与结构
    从 Responses API 到 Chat Completions:一个模型网关的设计复盘
    PHP请求API接口案例采集电商平台数据获取淘宝/天猫优惠券查询示例
    mysql 索引
    腾讯mini项目-【指标监控服务重构】2023-08-24
    【代码源每日一题Div1】路径计数2「动态规划 记忆化搜索」
    无关的表进行关联查询及null=null条件
    OneNote 教程,如何在 OneNote 中裁剪插入的图片?
    十五、Java中I/O流
  • 原文地址:https://blog.csdn.net/shangjg03/article/details/133171701