kafka相关问题集锦

1、你在写java 版的 kafka程序可能会遇到如下问题

参考地址：https://blog.csdn.net/gao23191879/article/details/80815078?utm_source=blogxgwz5

问题一：程序抛出了org.apache.kafka.common.errors.TimeoutException:

在application.yml 中加入下面这句话 ：logging.level.root:debug

然后再看报错，可以发现下面这个错误

错误：java.io.IOException: Can't resolve address: ubuntu:9092

原来是无法解析ubuntu。

解决办法：到C:WindowsSystem32driversetc ，用nopaid++打开hosts文件 加入下面这句话  远程主机的ip   ubuntu 

如   192.168.23.139     ubuntu

2、Kafka 启动时出现 AccessDeniedException

参考地址：https://blog.csdn.net/dsjtlmy/article/details/88557324

kafka 启动 AccessDeniedException: 

无法读取 logs oipicName0-delete 文件

可能原因：

将某主题标记成删除，然后手动删除logs目录，导致logs与zookeeper 不一致。

如果是demo环境，删除 zk的data目录（zoo.conf中配置），然后重启