客户端和kafka集群一直会断开连接,如果是第一次可以忽视,只是个警告,会自己恢复。
如果一直出现则需要看看生产者压力,网络是否稳定,check一下防火墙。
你问下安装的人,启动的时候如何替换的server.properties里的值(-1)。
上面解释的很清楚了。
谢谢大佬回答,还想问一下,如果server.properties里的brokerid值大于等于0 而且 和meta.properties里的brokerid值不一样,那是以server.properties的brokerid为准吗
默认情况下broker.id值为-1。Kafka broker的id值必须大于等于0时才有可能正常启动,但是并不是只能通过配置文件config/server.properties
来修改这个值,还可以通过meta.properties
文件或者自动生成功能来实现broker的id值的设置。
比如:meta.properties文件中的内容参考如下:
version=0
broker.id=1
meta.properties文件中记录了与当前Kafka版本对应的一个version字段。还有一个broker.id
即为当前Kafka broker
的id值。Kafka成功启动之后在每个根目录下都会有一个meta.properties文件。