我如何在本地特定端口上运行假kafka主题（内存中）来测试kafka？ [已关闭]

Question

我尝试了一些依赖项，它期望安装 docker 或抛出运行时异常

我想在没有 Docker 设置的情况下在指定端口本地运行一个假的 Kafka。

我的应用程序也不使用 spring 或 spring boot

Answer 1

Kafka 内置了 MockProducer 和 MockConsumer 类。

如果您想要对实际代理进行集成测试，那么是的，Testcontainers 是一个选项，或者还有其他库，例如

kafka-junit

或

embedded-kafka

，它们将下载并运行代理作为测试的一部分

https://github.com/salesforce/kafka-junit

Answer 2

• 下载 Zookeeper ：https://zookeeper.apache.org/releases.html
• 启动Zookeeper

# tar -zxf apache-zookeeper-3.5.9-bin.tar.gz
# mv apache-zookeeper-3.5.9-bin /usr/local/zookeeper
# mkdir -p /var/lib/zookeeper
# cp > /usr/local/zookeeper/conf/zoo.cfg << EOF
> tickTime=2000
> dataDir=/var/lib/zookeeper
> clientPort=2181
> EOF
# export JAVA_HOME=/usr/java/jdk-11.0.10
# /usr/local/zookeeper/bin/zkServer.sh start
JMX enabled by default
Using config: /usr/local/zookeeper/bin/../conf/zoo.cfg
Starting zookeeper ... STARTED

• 下载 Kafka：https://kafka.apache.org/downloads.html
• 启动卡夫卡

# tar -zxf kafka_2.13-2.7.0.tgz
# mv kafka_2.13-2.7.0 /usr/local/kafka
# mkdir /tmp/kafka-logs
# export JAVA_HOME=/usr/java/jdk-11.0.10
# /usr/local/kafka/bin/kafka-server-start.sh -daemon
/usr/local/kafka/config/server.properties
#

• 创建主题

/usr/local/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092 --create
--replication-factor 1 --partitions 1 --topic test
Created topic "test".

• 列出主题

/usr/local/kafka/bin/kafka-topics.sh --bootstrap-server localhost:9092
--describe --topic test
Topic:test    PartitionCount:1    ReplicationFactor:1    Configs:
    Topic: test    Partition: 0    Leader: 0    Replicas: 0 

我从《卡夫卡：权威指南》中得到了这个。我建议你读一下。