kafka模拟生产者和消费者命令

Apache Kafka是一个分布式流处理平台，常用于构建实时数据管道和事件驱动的应用程序。它支持高吞吐量、低延迟的发布订阅模型。在Kafka中，你可以通过命令行工具来创建和管理主题（topic）、生产消息（Producer）和消费消息（Consumer）。

**模拟生产者（Producer）命令**：

# 安装kafka-producer-perf-test.sh脚本
$ mkdir -p /usr/local/bin && \
    curl -L https://raw.githubusercontent.com/apache/kafka/$(curl -s https://kafka.apache.org/downloads | grep 'Latest release' | cut -d '"' -f4)/bin/kafka-producer-perf-test.sh > /usr/local/bin/kafka-producer-perf-test

# 生产消息（假设topic名为test-topic）
$ kafka-producer-perf-test.sh --broker-list localhost:9092 --topic test-topic --records 100000

**模拟消费者（Consumer）命令**：

# 安装kafka-console-consumer.sh脚本
$ mkdir -p /usr/local/bin && \
    curl -L https://raw.githubusercontent.com/apache/kafka/$(curl -s https://kafka.apache.org/downloads | grep 'Latest release' | cut -d '"' -f4)/bin/kafka-console-consumer.sh > /usr/local/bin/kafka-console-consumer

# 消费消息
$ kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic

以上命令需要将`localhost:9092`替换为你实际的Kafka服务器地址和端口。在使用前，请确保Kafka服务已经启动并且配置正确。