1，查询创建的 topic 列表报错：

解决方法:

vim /etc/hosts

将 host 里的

修改为：

再次查询就不报错了。

 

2,kafka的producer报错异常

kafka的producer出现异常，现象如下

需要改动config文件夹下的server.properties中的以下两个属性

1
2
3
zookeeper.connect=localhost:2181 #改成zookeeper.connect=10.0.30.221:2181 
#去掉host.name的注释
#host.name=localhost改成host.name=10.0.30.221

 亲测只需配置一下本地的hosts文件和服务器上的hosts文件，使ip和服务器的hostname对应即可，并不用改其他配置文件，配置文件中保持使用hostname，总之一句话，所有使用ip参数的位置都换成服务器的hostname并配置好hosts文件即可！！

 

 

 

Java访问kafka的时候java.nio.channels.ClosedChannelException解决办法

 

kafka启动报：java.lang.OutOfMemoryError: Map failed

 

 

原因：

安装在本地jdk的JVM是32位的，Linxu系统是64位的

查看JVM位数

[root@r-wb-16 bin]# java -d64 -version
Error: This Java instance does not support a 64-bit JVM.
Please install the desired version.
[root@r-wb-16 bin]# 
[root@r-wb-16 bin]# java -d32 -version
java version "1.8.0_311"
Java(TM) SE Runtime Environment (build 1.8.0_311-b11)
Java HotSpot(TM) Server VM (build 25.311-b11, mixed mode)

安装64位JDK后查看

[root@r-wb-16 ~]#  java -d64 -version
java version "1.8.0_321"
Java(TM) SE Runtime Environment (build 1.8.0_321-b07)
Java HotSpot(TM) 64-Bit Server VM (build 25.321-b07, mixed mode)
[root@r-wb-16 ~]# java -d32 -version
Error: This Java instance does not support a 32-bit JVM.
Please install the desired version.

重新启动kafka，启动正常

 

转自：
https://www.cnblogs.com/codehello/articles/9293722.html