生产者发送消息到 kafka 中,然后控制台报错

然后根据日志查看 kafka 的源码发现了问题原因

说的是MBean已经注册了,然后报异常了,这样就会导致生产者的kafka注册失败, 原因是项目上生产者没有配置clientId,默认都是空导致的, 多个生产者(项目)注册到kafka集群中的 id 都相同。 解决办法就行给生产者配置 client_id

spring:
	kafka:
		producer:
			client-id: ${spring.application.name}${random.uuid}

这样每个生产者注入到集群 kafka 中的 client-id 不同了那么就不会出现别人注入不进去的情况了