根据业务区分kafka的groupid传入调用放的全限定类名作为groupid
时间: 2023-08-15 21:46:07 浏览: 127
Java API方式调用Kafka各种协议的方法
这个做法是可行的,可以根据业务来区分groupid。使用全限定类名作为groupid也可以确保groupid的唯一性,避免不同的应用误用同一个groupid。不过需要注意的是,同一个应用如果使用了不同的全限定类名作为groupid,那么它们将会被Kafka视为不同的消费者组,这会导致消息重复消费的问题。因此,在使用全限定类名作为groupid时,需要保证同一个应用的所有消费者实例使用相同的全限定类名作为groupid。另外,需要注意的是,groupid的长度不能超过255个字符,因此需要根据实际情况进行调整。
阅读全文