目录 start

1. Kafka
   1. 安装
      1. Docker

目录 end|2020-06-24 02:06|

Official Doc

参考: 初探Kafka Streams

• ksql

参考: Kafka Topic Architecture

参考: Apche Kafka 的生与死 – failover 机制详解 解释 I wrote this conflicted ephemeral node

参考: docker部署kafka

Kafka 容器的创建强制性依赖 Zookeeper, 但是在使用中可以直接使用Kafka

    # 启动 Zookeeper
    docker run -d --name kafka-zookeeper -p 2181:2181 --volume /etc/localtime:/etc/localtime wurstmeister/zookeeper

    # 启动 Kafka
    docker run -d --name kafka -p 9092:9092 --link kafka-zookeeper --env KAFKA_ZOOKEEPER_CONNECT=kafka-zookeeper:2181 --env KAFKA_ADVERTISED_HOST_NAME=localhost --env KAFKA_ADVERTISED_PORT=9092 --volume /etc/localtime:/etc/localtime wurstmeister/kafka

Hello World

/opt/kafka_xxx 目录下

1. 创建一个 topic bin/kafka-topics.sh --create --zookeeper kafka-zookeeper:2181 --replication-factor 1 --partitions 1 --topic mykafka
2. 运行一个消息生产者并指定topic bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
   • 此时会提供一个输入命令行, 就能输入发送的消息内容
3. 查看所有的topic列表 bin/kafka-topics.sh --list --zookeeper kafka-zookeeper:2181
   • 或者 bin/kafka-topics.sh --list --bootstrap-server 127.0.0.1:9092
4. 运行一个消费者并指定topic bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mykafka --from-beginning
   • 会收到消息生产者输入的内容