• 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
    

  • 相关阅读:
    SparkStreaming消费kafka存储到Elasticsearch
    信息安全和网络空间安全选哪个?
    关于CUDA+Torch+TorchVision+Python环境配置问题
    【学生网页设计作品 】关于HTML公益主题网页设计——公益电信诈骗10页
    章节二:Rasa创建一个简单助手
    BFS专题5 跨步迷宫
    Nginx中proxy_pass的使用介绍
    HTML-DAY1
    软考-信息安全工程师-下午题常考
    Read Committed
  • 原文地址:https://blog.csdn.net/shangjg03/article/details/133171701