ProblemSummary - ErikJiang/kafka_cluster_example GitHub Wiki

1. 问题：driver failed programming external connectivity on endpoint

处理：

# 检测使用该端口的容器
docker container ls -a
# 删除该端口的容器
docker container rm -f
# 重启 docker 服务

Windows 用户需要在 控制面板 \ 所有控制面板项 \ 电源选项 \ 系统设置 中，将关机设置中的快速启动禁用掉，原因见：https://stackoverflow.com/a/47818614

2. 问题：kafka 服务关闭并报错：NodeExistsException

ERROR [KafkaServer id=1] Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)
org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists

处理：检查 volumes 本地挂载的目录中是否存在数据文件，若存在，尝试清空文件重新构建服务

3. 问题：并发消息时，消费组中始终仅有消费者A能够订阅到消息，其他消费者无任何数据接收？

处理：检查发现，发布消息的 topic 下仅有一个 partition，这即是仅有一个消费者能够订阅消息的原因，kafka 中一个 partition 对应一个消费者；解决方法，即在创建 topic 时，需要设置多个partition，partition number > consumer number;